| Index: content/child/url_response_body_consumer.cc
|
| diff --git a/content/child/url_response_body_consumer.cc b/content/child/url_response_body_consumer.cc
|
| index 6874b5053a77b1b5b70d69294da7257ef86790e3..5016ee3a5b6c0646e383d43c26b745bbcdd6c816 100644
|
| --- a/content/child/url_response_body_consumer.cc
|
| +++ b/content/child/url_response_body_consumer.cc
|
| @@ -49,7 +49,13 @@ URLResponseBodyConsumer::URLResponseBodyConsumer(
|
| resource_dispatcher_(resource_dispatcher),
|
| handle_(std::move(handle)),
|
| handle_watcher_(task_runner),
|
| - has_seen_end_of_data_(!handle_.is_valid()) {
|
| + has_seen_end_of_data_(!handle_.is_valid()) {}
|
| +
|
| +URLResponseBodyConsumer::~URLResponseBodyConsumer() {}
|
| +
|
| +void URLResponseBodyConsumer::Start(base::SingleThreadTaskRunner* task_runner) {
|
| + if (has_been_cancelled_)
|
| + return;
|
| handle_watcher_.Start(
|
| handle_.get(), MOJO_HANDLE_SIGNAL_READABLE,
|
| base::Bind(&URLResponseBodyConsumer::OnReadable, base::Unretained(this)));
|
| @@ -58,8 +64,6 @@ URLResponseBodyConsumer::URLResponseBodyConsumer(
|
| MOJO_RESULT_OK));
|
| }
|
|
|
| -URLResponseBodyConsumer::~URLResponseBodyConsumer() {}
|
| -
|
| void URLResponseBodyConsumer::OnComplete(
|
| const ResourceRequestCompletionStatus& status) {
|
| if (has_been_cancelled_)
|
|
|