Remove deprecated APIs from WebDataConsumerHandle.

Source/core/xmlhttprequest/XMLHttpRequest.cpp

 /*
  *  Copyright (C) 2004, 2006, 2008 Apple Inc. All rights reserved.
  *  Copyright (C) 2005-2007 Alexey Proskuryakov <ap@webkit.org>
  *  Copyright (C) 2007, 2008 Julien Chaffraix <jchaffraix@webkit.org>
  *  Copyright (C) 2008, 2011 Google Inc. All rights reserved.
  *  Copyright (C) 2012 Intel Corporation
  *
  *  This library is free software; you can redistribute it and/or
  *  modify it under the terms of the GNU Lesser General Public
  *  License as published by the Free Software Foundation; either
@@ skipping 143 matching lines @@
     ReadableStreamSource(XMLHttpRequest* owner, PassOwnPtr<WebDataConsumerHandle> body)
         : m_owner(owner)
         , m_body(body)
         , m_needsMore(false)
         , m_hasReadBody(false)
         , m_hasGotDidFinishLoading(false)
     {
         if (m_body) {
             // |m_body| has |this| as a raw pointer, but it is not a problem
             // because |this| owns |m_body|.
-            m_body->registerClient(this);
+            m_reader = m_body->obtainReader(this);
         }
     }
     ~ReadableStreamSource() override { }
 
     WebDataConsumerHandle* body() { return m_body.get(); }
 
     // UnderlyingSource
     void pullSource() override
     {
         if (m_body) {
@@ skipping 47 matching lines @@
         UnderlyingSource::trace(visitor);
     }
 
 private:
     void enqueueToStreamFromHandle()
     {
         ASSERT(m_body);
         while (m_needsMore) {
             const void* buffer = nullptr;
             size_t size = 0;
-            Result result = m_body->beginRead(&buffer, WebDataConsumerHandle::FlagNone, &size);
+            Result result = m_reader->beginRead(&buffer, WebDataConsumerHandle::FlagNone, &size);
             if (result == WebDataConsumerHandle::ShouldWait)
                 return;
             if (result == WebDataConsumerHandle::Done) {
                 m_hasReadBody = true;
                 if (m_hasGotDidFinishLoading) {
                     // If we got didFinishLoading, we should close the stream
                     // here. If we didn't, it's possible that the loading
                     // actually failed and didFail will be notified, so we
                     // don't close the stream.
                     m_stream->close();
                 }
                 m_needsMore = false;
                 return;
             }
             if (result != WebDataConsumerHandle::Ok) {
                 m_stream->error(DOMException::create(NetworkError));
                 m_owner->abort();
                 m_needsMore = false;
                 return;
             }
             RefPtr<DOMArrayBuffer> arrayBuffer = DOMArrayBuffer::create(size, 1);
             memcpy(arrayBuffer->data(), buffer, size);
-            result = m_body->endRead(size);
+            result = m_reader->endRead(size);
             if (result != WebDataConsumerHandle::Ok) {
                 m_stream->error(DOMException::create(NetworkError));
                 m_owner->abort();
                 m_needsMore = false;
                 return;
             }
             m_needsMore = m_stream->enqueue(DOMUint8Array::create(arrayBuffer.release(), 0, size));
         }
     }
 
     // This is RawPtr in non-oilpan build to avoid the reference cycle. To
     // avoid use-after free, the associated ReadableStream must be closed
     // or errored when m_owner is gone.
     RawPtrWillBeMember<XMLHttpRequest> m_owner;
     Member<ReadableStreamImpl<ReadableStreamChunkTypeTraits<DOMArrayBufferView>>> m_stream;
     OwnPtr<WebDataConsumerHandle> m_body;
+    OwnPtr<WebDataConsumerHandle::Reader> m_reader;
     bool m_needsMore;
     bool m_hasReadBody;
     bool m_hasGotDidFinishLoading;
 };
 
 class XMLHttpRequest::BlobLoader final : public GarbageCollectedFinalized<XMLHttpRequest::BlobLoader>, public FileReaderLoaderClient {
 public:
     static BlobLoader* create(XMLHttpRequest* xhr, PassRefPtr<BlobDataHandle> handle)
     {
         return new BlobLoader(xhr, handle);
@@ skipping 1582 matching lines @@
     visitor->trace(m_responseDocumentParser);
     visitor->trace(m_progressEventThrottle);
     visitor->trace(m_upload);
     visitor->trace(m_blobLoader);
     XMLHttpRequestEventTarget::trace(visitor);
     DocumentParserClient::trace(visitor);
     ActiveDOMObject::trace(visitor);
 }
 
 } // namespace blink