[Cronet] Change interface APIs to abstract classes

components/cronet/android/java/src/org/chromium/net/urlconnection/CronetBufferedOutputStream.java

 // Copyright 2015 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.
 
 package org.chromium.net.urlconnection;
 
+import org.chromium.net.UploadDataProvider;
 import org.chromium.net.UploadDataSink;
 
 import java.io.IOException;
 import java.net.ProtocolException;
 import java.nio.ByteBuffer;
 
 /**
  * An implementation of {@link java.io.OutputStream} that buffers entire request
  * body in memory. This is used when neither
  * {@link CronetHttpURLConnection#setFixedLengthStreamingMode}
  * nor {@link CronetHttpURLConnection#setChunkedStreamingMode} is set.
  */
 final class CronetBufferedOutputStream extends CronetOutputStream {
     // QUIC uses a read buffer of 14520 bytes, SPDY uses 2852 bytes, and normal
     // stream uses 16384 bytes. Therefore, use 16384 for now to avoid growing
     // the buffer too many times.
     private static final int INITIAL_BUFFER_SIZE = 16384;
     // If content length is not passed in the constructor, this is -1.
     private final int mInitialContentLength;
     private final CronetHttpURLConnection mConnection;
+    private final UploadDataProvider mUploadDataProvider = new UploadDataProviderImpl();
     // Internal buffer that is used to buffer the request body.
     private ByteBuffer mBuffer;
     private boolean mConnected = false;
 
     /**
      * Package protected constructor.
      * @param connection The CronetHttpURLConnection object.
      * @param contentLength The content length of the request body. It must not
      *            be smaller than 0 or bigger than {@link Integer.MAX_VALUE}.
      */
@@ skipping 87 matching lines @@
         mBuffer.flip();
     }
 
     @Override
     void checkReceivedEnoughContent() throws IOException {
         // Already checked in setConnected. Skip the check here, since mBuffer
         // might be flipped.
     }
 
     @Override
-    public long getLength() {
-        // This method is supposed to be called just before starting the request.
-        // If content length is not initially passed in, the number of bytes
-        // written will be used as the content length.
-        // TODO(xunjieli): Think of a less fragile way, since getLength() can be
-        // potentially called in other places in the future.
-        if (mInitialContentLength == -1) {
-            return mBuffer.position();
-        }
-        return mInitialContentLength;
+    UploadDataProvider getUploadDataProvider() {
+        return mUploadDataProvider;
     }
 
-    @Override
-    public void read(UploadDataSink uploadDataSink, ByteBuffer byteBuffer) {
-        int availableSpace = byteBuffer.capacity() - byteBuffer.position();
-        if (availableSpace  < mBuffer.limit() - mBuffer.position()) {
-            byteBuffer.put(mBuffer.array(), mBuffer.position(), availableSpace);
-            mBuffer.position(mBuffer.position() + availableSpace);
-        } else {
-            byteBuffer.put(mBuffer);
+    private class UploadDataProviderImpl extends UploadDataProvider {
+        @Override
+        public long getLength() {
+            // This method is supposed to be called just before starting the request.
+            // If content length is not initially passed in, the number of bytes
+            // written will be used as the content length.
+            // TODO(xunjieli): Think of a less fragile way, since getLength() can be
+            // potentially called in other places in the future.
+            if (mInitialContentLength == -1) {
+                return mBuffer.position();
+            }
+            return mInitialContentLength;
         }
-        uploadDataSink.onReadSucceeded(false);
-    }
 
-    @Override
-    public void rewind(UploadDataSink uploadDataSink) {
-        mBuffer.position(0);
-        uploadDataSink.onRewindSucceeded();
+        @Override
+        public void read(UploadDataSink uploadDataSink, ByteBuffer byteBuffer) {
+            int availableSpace = byteBuffer.capacity() - byteBuffer.position();
+            if (availableSpace < mBuffer.limit() - mBuffer.position()) {
+                byteBuffer.put(mBuffer.array(), mBuffer.position(), availableSpace);
+                mBuffer.position(mBuffer.position() + availableSpace);
+            } else {
+                byteBuffer.put(mBuffer);
+            }
+            uploadDataSink.onReadSucceeded(false);
+        }
+
+        @Override
+        public void rewind(UploadDataSink uploadDataSink) {
+            mBuffer.position(0);
+            uploadDataSink.onRewindSucceeded();
+        }
     }
 }