Java API for mojo system.

mojo/system/android/src/org/chromium/mojo/system/DataPipeConsumerHandleImpl.java

Index: mojo/system/android/src/org/chromium/mojo/system/DataPipeConsumerHandleImpl.java
diff --git a/mojo/system/android/src/org/chromium/mojo/system/DataPipeConsumerHandleImpl.java b/mojo/system/android/src/org/chromium/mojo/system/DataPipeConsumerHandleImpl.java
new file mode 100644
index 0000000000000000000000000000000000000000..7644aeb29f0966c6a1c0d24fe78d4948b735f14d
--- /dev/null
+++ b/mojo/system/android/src/org/chromium/mojo/system/DataPipeConsumerHandleImpl.java
@@ -0,0 +1,58 @@
+// 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;
+
+/**
+ * TODO(qsr): Insert description here.
+ */
+public class DataPipeConsumerHandleImpl extends HandleImpl implements ConsumerHandle {
+
+    /**
+     * TODO(qsr):
+     */
+    public DataPipeConsumerHandleImpl(CoreImpl core, int mojoHandle) {
+        super(core, mojoHandle);
+    }
+
+    /**
+     * TODO(qsr):
+     */
+    DataPipeConsumerHandleImpl(HandleImpl other) {
+        super(other);
+    }
+
+    /*
+     * (non-Javadoc)
+     * @see org.chromium.mojo.system.DataPipe.ConsumerHandle#readData(...)
+     */
+    @Override
+    public int readData(ByteBuffer elements, ReadFlags flags) {
+        return mCore.readData(this, elements, flags);
+    }
+
+    /*
+     * (non-Javadoc)
+     * @see org.chromium.mojo.system.DataPipe.ConsumerHandle#beingReadData(...)
+     */
+    @Override
+    public ByteBuffer beingReadData(int numBytes, ReadFlags flags) {
+        return mCore.beingReadData(this, numBytes, flags);
+    }
+
+    /*
+     * (non-Javadoc)
+     * @see org.chromium.mojo.system.DataPipe.ConsumerHandle#endReadData(...)
+     */
+    @Override
+    public void endReadData(int numBytesRead) {
+        mCore.endReadData(this, numBytesRead);
+    }
+
+}