| 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);
|
| + }
|
| +
|
| +}
|
|
|