Add mojo <--> net IO adapters.

mojo/services/network/url_loader_impl.h

 // 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.
 
 #ifndef MOJO_SERVICES_NETWORK_URL_LOADER_IMPL_H_
 #define MOJO_SERVICES_NETWORK_URL_LOADER_IMPL_H_
 
 #include "base/memory/scoped_ptr.h"
 #include "base/memory/weak_ptr.h"
 #include "mojo/common/handle_watcher.h"
 #include "mojo/public/cpp/bindings/interface_impl.h"
 #include "mojo/services/public/interfaces/network/url_loader.mojom.h"
 #include "net/base/net_errors.h"
 #include "net/url_request/url_request.h"
 
 namespace mojo {
+
 class NetworkContext;
+class NetToMojoPendingBuffer;
 
 class URLLoaderImpl : public InterfaceImpl<URLLoader>,
                       public net::URLRequest::Delegate {
  public:
   explicit URLLoaderImpl(NetworkContext* context);
   virtual ~URLLoaderImpl();
 
  private:
-  class PendingWriteToDataPipe;
-  class DependentIOBuffer;
-
   // URLLoader methods:
   virtual void Start(
       URLRequestPtr request,
       const Callback<void(URLResponsePtr)>& callback) override;
   virtual void FollowRedirect(
       const Callback<void(URLResponsePtr)>& callback) override;
   virtual void QueryStatus(
       const Callback<void(URLLoaderStatusPtr)>& callback) override;
 
   // net::URLRequest::Delegate methods:
   virtual void OnReceivedRedirect(net::URLRequest* url_request,
                                   const net::RedirectInfo& redirect_info,
                                   bool* defer_redirect) override;
   virtual void OnResponseStarted(net::URLRequest* url_request) override;
   virtual void OnReadCompleted(net::URLRequest* url_request, int bytes_read)
       override;
 
   void SendError(
       int error,
       const Callback<void(URLResponsePtr)>& callback);
   void SendResponse(URLResponsePtr response);
   void OnResponseBodyStreamReady(MojoResult result);
-  void WaitToReadMore();
   void ReadMore();
   void DidRead(uint32_t num_bytes, bool completed_synchronously);
 
   NetworkContext* context_;
   scoped_ptr<net::URLRequest> url_request_;
   Callback<void(URLResponsePtr)> callback_;
   ScopedDataPipeProducerHandle response_body_stream_;
-  scoped_refptr<PendingWriteToDataPipe> pending_write_;
+  scoped_refptr<NetToMojoPendingBuffer> pending_write_;
   common::HandleWatcher handle_watcher_;
   uint32 response_body_buffer_size_;
   bool auto_follow_redirects_;
 
   base::WeakPtrFactory<URLLoaderImpl> weak_ptr_factory_;
 };
 
 }  // namespace mojo
 
 #endif  // MOJO_SERVICES_NETWORK_URL_LOADER_IMPL_H_