Index: mojo/android/system/src/org/chromium/mojo/system/DataPipeConsumerHandleImpl.java |
diff --git a/mojo/android/system/src/org/chromium/mojo/system/DataPipeConsumerHandleImpl.java b/mojo/android/system/src/org/chromium/mojo/system/DataPipeConsumerHandleImpl.java |
new file mode 100644 |
index 0000000000000000000000000000000000000000..84985bfe82315310cf7c733062725206324a4059 |
--- /dev/null |
+++ b/mojo/android/system/src/org/chromium/mojo/system/DataPipeConsumerHandleImpl.java |
@@ -0,0 +1,63 @@ |
+// 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. |
+ |
+package org.chromium.mojo.system; |
+ |
+import org.chromium.mojo.system.DataPipe.ConsumerHandle; |
+import org.chromium.mojo.system.DataPipe.ReadFlags; |
+ |
+import java.nio.ByteBuffer; |
+ |
+/** |
+ * Implementation of {@link ConsumerHandle}. |
+ */ |
+class DataPipeConsumerHandleImpl extends HandleImpl implements ConsumerHandle { |
+ |
+ /** |
+ * @see HandleImpl#HandleImpl(CoreImpl, int) |
+ */ |
+ DataPipeConsumerHandleImpl(CoreImpl core, int mojoHandle) { |
+ super(core, mojoHandle); |
+ } |
+ |
+ /** |
+ * @see HandleImpl#HandleImpl(UntypedHandleImpl) |
+ */ |
+ DataPipeConsumerHandleImpl(UntypedHandleImpl other) { |
+ super(other); |
+ } |
+ |
+ /** |
+ * @see ConsumerHandle#discardData(int, ReadFlags) |
+ */ |
+ @Override |
+ public int discardData(int numBytes, ReadFlags flags) { |
+ return mCore.discardData(this, numBytes, flags); |
+ } |
+ |
+ /** |
+ * @see ConsumerHandle#readData(ByteBuffer, ReadFlags) |
+ */ |
+ @Override |
+ public int readData(ByteBuffer elements, ReadFlags flags) { |
+ return mCore.readData(this, elements, flags); |
+ } |
+ |
+ /** |
+ * @see ConsumerHandle#beginReadData(int, ReadFlags) |
+ */ |
+ @Override |
+ public ByteBuffer beginReadData(int numBytes, ReadFlags flags) { |
+ return mCore.beginReadData(this, numBytes, flags); |
+ } |
+ |
+ /** |
+ * @see ConsumerHandle#endReadData(int) |
+ */ |
+ @Override |
+ public void endReadData(int numBytesRead) { |
+ mCore.endReadData(this, numBytesRead); |
+ } |
+ |
+} |