Use per-frame TaskRunner instead of thread's default in DataConsumerHandle

third_party/WebKit/Source/core/loader/DocumentThreadableLoader.cpp

 /*
  * Copyright (C) 2011, 2012 Google Inc. All rights reserved.
  * Copyright (C) 2013, Intel Corporation
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions are
  * met:
  *
  *     * Redistributions of source code must retain the above copyright
  * notice, this list of conditions and the following disclaimer.
@@ skipping 51 matching lines @@
 namespace blink {
 
 namespace {
 
 class EmptyDataHandle final : public WebDataConsumerHandle {
 private:
     class EmptyDataReader final : public WebDataConsumerHandle::Reader {
     public:
         explicit EmptyDataReader(WebDataConsumerHandle::Client* client) : m_factory(this)
         {
-            Platform::current()->currentThread()->getWebTaskRunner()->postTask(BLINK_FROM_HERE, WTF::bind(&EmptyDataReader::notify, m_factory.createWeakPtr(), WTF::unretained(client)));
+            if (client)
+                client->getTaskRunner()->postTask(BLINK_FROM_HERE, WTF::bind(&EmptyDataReader::notify, m_factory.createWeakPtr(), WTF::unretained(client)));
         }
     private:
         Result beginRead(const void** buffer, WebDataConsumerHandle::Flags, size_t *available) override
         {
             *available = 0;
             *buffer = nullptr;
             return Done;
         }
         Result endRead(size_t) override
         {
             return WebDataConsumerHandle::UnexpectedError;
         }
         void notify(WebDataConsumerHandle::Client* client)
         {
-            client->didGetReadable();
+            if (client)
+                client->didGetReadable();
         }
         WeakPtrFactory<EmptyDataReader> m_factory;
     };
 
     std::unique_ptr<Reader> obtainReader(Client* client) override
     {
         return WTF::wrapUnique(new EmptyDataReader(client));
     }
     const char* debugName() const override { return "EmptyDataHandle"; }
 };
@@ skipping 917 matching lines @@
     return m_securityOrigin ? m_securityOrigin.get() : document().getSecurityOrigin();
 }
 
 Document& DocumentThreadableLoader::document() const
 {
     ASSERT(m_document);
     return *m_document;
 }
 
 } // namespace blink