Index: components/cronet/android/url_request_adapter.cc |
diff --git a/components/cronet/android/url_request_adapter.cc b/components/cronet/android/url_request_adapter.cc |
index 9d9e29b2ce3258ab2a86ee8e506eb99426c7731c..5bd817c27839b14193aedd613af2ef41a069f33e 100644 |
--- a/components/cronet/android/url_request_adapter.cc |
+++ b/components/cronet/android/url_request_adapter.cc |
@@ -76,8 +76,7 @@ void URLRequestAdapter::AppendChunk(const char* bytes, int bytes_len, |
VLOG(1) << "AppendChunk, len: " << bytes_len << ", last: " << is_last_chunk; |
scoped_ptr<char[]> buf(new char[bytes_len]); |
memcpy(buf.get(), bytes, bytes_len); |
- context_->GetNetworkTaskRunner()->PostTask( |
- FROM_HERE, |
+ context_->RunTaskAfterContextInit( |
base::Bind(&URLRequestAdapter::OnAppendChunk, |
base::Unretained(this), |
Passed(buf.Pass()), |
@@ -107,10 +106,8 @@ std::string URLRequestAdapter::GetNegotiatedProtocol() const { |
} |
void URLRequestAdapter::Start() { |
- context_->GetNetworkTaskRunner()->PostTask( |
- FROM_HERE, |
- base::Bind(&URLRequestAdapter::OnInitiateConnection, |
- base::Unretained(this))); |
+ context_->RunTaskAfterContextInit(base::Bind( |
+ &URLRequestAdapter::OnInitiateConnection, base::Unretained(this))); |
} |
void URLRequestAdapter::OnAppendChunk(const scoped_ptr<char[]> bytes, |
@@ -158,8 +155,7 @@ void URLRequestAdapter::Cancel() { |
canceled_ = true; |
- context_->GetNetworkTaskRunner()->PostTask( |
- FROM_HERE, |
+ context_->RunTaskAfterContextInit( |
base::Bind(&URLRequestAdapter::OnCancelRequest, base::Unretained(this))); |
} |
@@ -174,8 +170,8 @@ void URLRequestAdapter::OnCancelRequest() { |
} |
void URLRequestAdapter::Destroy() { |
- context_->GetNetworkTaskRunner()->PostTask( |
- FROM_HERE, base::Bind(&URLRequestAdapter::OnDestroyRequest, this)); |
+ context_->RunTaskAfterContextInit( |
+ base::Bind(&URLRequestAdapter::OnDestroyRequest, this)); |
} |
// static |