public class ReadableBbqChannel extends AbstractBbqChannel implements ReadableJslipcByteChannel, InterruptibleChannel
ReadableJslipcByteChannel
implementation that reads the data from an underlying
ByteBufferQueue
.JslipcChannel.JslipcChannelState
closed, queue
Constructor and Description |
---|
ReadableBbqChannel(ByteBufferQueue queue) |
Modifier and Type | Method and Description |
---|---|
InputStream |
newInputStream() |
int |
read(ByteBuffer dst) |
checkClosed, close, getState, getTimeout, isOpen, setTimeout, sleep, waitForInitialization, waitForNonEmpty, waitForNonFull
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getState
close
public ReadableBbqChannel(ByteBufferQueue queue)
public int read(ByteBuffer dst) throws IOException
read
in interface ReadableByteChannel
IOException
public InputStream newInputStream()
Copyright © 2014. All Rights Reserved.