[Streams] Pass WebDataConsumerHandle when the response arrives.

Source/core/loader/DocumentLoader.cpp

 /*
  * Copyright (C) 2006, 2007, 2008 Apple Inc. All rights reserved.
  * Copyright (C) 2011 Google Inc. All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions
  * are met:
  *
  * 1.  Redistributions of source code must retain the above copyright
  *     notice, this list of conditions and the following disclaimer.
@@ skipping 422 matching lines @@
     frame()->document()->enforceSandboxFlags(SandboxOrigin);
     if (FrameOwner* owner = frame()->owner())
         owner->dispatchLoad();
 
     // The load event might have detached this frame. In that case, the load will already have been cancelled during detach.
     if (frameLoader())
         cancelMainResourceLoad(ResourceError::cancelledError(m_request.url()));
     return;
 }
 
-void DocumentLoader::responseReceived(Resource* resource, const ResourceResponse& response)
+void DocumentLoader::responseReceived(Resource* resource, const ResourceResponse& response, PassOwnPtr<WebDataConsumerHandle> handle)
 {
     ASSERT_UNUSED(resource, m_mainResource == resource);
+    ASSERT_UNUSED(handle, !handle);
     RefPtr<DocumentLoader> protect(this);
 
     m_applicationCacheHost->didReceiveResponseForMainResource(response);
 
     // The memory cache doesn't understand the application cache or its caching rules. So if a main resource is served
     // from the application cache, ensure we don't save the result for future use. All responses loaded
     // from appcache will have a non-zero appCacheID().
     if (response.appCacheID())
         memoryCache()->remove(m_mainResource.get());
 
@@ skipping 217 matching lines @@
         return false;
 
     ASSERT(m_archiveResourceCollection);
     ArchiveResource* archiveResource = m_archiveResourceCollection->archiveResourceForURL(request.url());
     if (!archiveResource) {
         cachedResource->error(Resource::LoadError);
         return true;
     }
 
     cachedResource->setLoading(true);
-    cachedResource->responseReceived(archiveResource->response());
+    cachedResource->responseReceived(archiveResource->response(), nullptr);
     SharedBuffer* data = archiveResource->data();
     if (data)
         cachedResource->appendData(data->data(), data->size());
     cachedResource->finish();
     return true;
 }
 
 const AtomicString& DocumentLoader::responseMIMEType() const
 {
     return m_response.mimeType();
@@ skipping 141 matching lines @@
 // This is only called by FrameLoader::replaceDocumentWhileExecutingJavaScriptURL()
 void DocumentLoader::replaceDocumentWhileExecutingJavaScriptURL(const DocumentInit& init, const String& source, Document* ownerDocument)
 {
     m_writer = createWriterFor(ownerDocument, init, mimeType(), m_writer ? m_writer->encoding() : emptyAtom, true);
     if (!source.isNull())
         m_writer->appendReplacingData(source);
     endWriting(m_writer.get());
 }
 
 } // namespace blink