Reduce SuspendableObjects

third_party/WebKit/Source/modules/fetch/BodyStreamBuffer.cpp

 // Copyright 2014 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "modules/fetch/BodyStreamBuffer.h"
 
 #include "bindings/core/v8/ScriptState.h"
 #include "bindings/core/v8/V8HiddenValue.h"
 #include "bindings/core/v8/V8ThrowException.h"
 #include "core/dom/DOMArrayBuffer.h"
 #include "core/dom/DOMTypedArray.h"
 #include "core/dom/ExceptionCode.h"
 #include "core/streams/ReadableStreamController.h"
 #include "core/streams/ReadableStreamOperations.h"
 #include "modules/fetch/Body.h"
 #include "modules/fetch/ReadableStreamBytesConsumer.h"
 #include "platform/blob/BlobData.h"
 #include "platform/network/EncodedFormData.h"
 #include <memory>
 
 namespace blink {
 
 class BodyStreamBuffer::LoaderClient final
     : public GarbageCollectedFinalized<LoaderClient>,
-      public SuspendableObject,
+      public ContextLifecycleObserver,
       public FetchDataLoader::Client {
   WTF_MAKE_NONCOPYABLE(LoaderClient);
   USING_GARBAGE_COLLECTED_MIXIN(LoaderClient);
 
  public:
   LoaderClient(ExecutionContext* executionContext,
                BodyStreamBuffer* buffer,
                FetchDataLoader::Client* client)
-      : SuspendableObject(executionContext),
+      : ContextLifecycleObserver(executionContext),
         m_buffer(buffer),
-        m_client(client) {
-    suspendIfNeeded();
-  }
+        m_client(client) {}
 
   void didFetchDataLoadedBlobHandle(
       PassRefPtr<BlobDataHandle> blobDataHandle) override {
     m_buffer->endLoading();
     m_client->didFetchDataLoadedBlobHandle(std::move(blobDataHandle));
   }
 
   void didFetchDataLoadedArrayBuffer(DOMArrayBuffer* arrayBuffer) override {
     m_buffer->endLoading();
     m_client->didFetchDataLoadedArrayBuffer(arrayBuffer);
@@ skipping 10 matching lines @@
   }
 
   void didFetchDataLoadFailed() override {
     m_buffer->endLoading();
     m_client->didFetchDataLoadFailed();
   }
 
   DEFINE_INLINE_TRACE() {
     visitor->trace(m_buffer);
     visitor->trace(m_client);
-    SuspendableObject::trace(visitor);
+    ContextLifecycleObserver::trace(visitor);
     FetchDataLoader::Client::trace(visitor);
   }
 
  private:
   void contextDestroyed() override { m_buffer->stopLoading(); }
 
   Member<BodyStreamBuffer> m_buffer;
   Member<FetchDataLoader::Client> m_client;
 };
 
@@ skipping 306 matching lines @@
   }
   if (isErrored)
     return BytesConsumer::createErrored(BytesConsumer::Error("error"));
 
   DCHECK(consumer);
   consumer->clearClient();
   return consumer;
 }
 
 }  // namespace blink