public abstract class FixedPayloadFrameSourceChannel extends StreamSourceFrameChannel
channel, type, wsChannel
Modifier | Constructor and Description |
---|---|
protected |
FixedPayloadFrameSourceChannel(WebSocketChannel.StreamSourceChannelControl streamSourceChannelControl,
org.xnio.channels.StreamSourceChannel channel,
WebSocketChannel wsChannel,
WebSocketFrameType type,
long payloadSize,
int rsv,
boolean finalFragment,
ChannelFunction... functions) |
Modifier and Type | Method and Description |
---|---|
protected void |
afterRead(ByteBuffer buffer,
int position,
int length)
Caled after data was read into the
ByteBuffer |
protected void |
complete()
Is called once the whole frame was read.
|
protected boolean |
isComplete()
Returns
true if the frame was complete. |
protected int |
read0(ByteBuffer dst) |
protected long |
read0(ByteBuffer[] dsts) |
protected long |
read0(ByteBuffer[] dsts,
int offset,
int length) |
protected long |
transferTo0(long count,
ByteBuffer throughBuffer,
org.xnio.channels.StreamSinkChannel target) |
protected long |
transferTo0(long position,
long count,
FileChannel target) |
awaitReadable, awaitReadable, close, discard, getCloseSetter, getIoThread, getOption, getPayloadSize, getReadSetter, getReadThread, getRsv, getType, getWebSocketChannel, getWorker, isFinalFragment, isOpen, isReadResumed, queueListener, read, read, read, resumeReads, setOption, shutdownReads, supportsOption, suspendReads, transferTo, transferTo, wakeupReads
protected FixedPayloadFrameSourceChannel(WebSocketChannel.StreamSourceChannelControl streamSourceChannelControl, org.xnio.channels.StreamSourceChannel channel, WebSocketChannel wsChannel, WebSocketFrameType type, long payloadSize, int rsv, boolean finalFragment, ChannelFunction... functions)
protected final long transferTo0(long position, long count, FileChannel target) throws IOException
transferTo0
in class StreamSourceFrameChannel
IOException
StreamSourceChannel.transferTo(long, long, FileChannel)
protected final long transferTo0(long count, ByteBuffer throughBuffer, org.xnio.channels.StreamSinkChannel target) throws IOException
transferTo0
in class StreamSourceFrameChannel
IOException
StreamSourceChannel.transferTo(long, ByteBuffer, StreamSinkChannel)
protected int read0(ByteBuffer dst) throws IOException
read0
in class StreamSourceFrameChannel
IOException
ReadableByteChannel.read(ByteBuffer)
protected final long read0(ByteBuffer[] dsts) throws IOException
read0
in class StreamSourceFrameChannel
IOException
ScatteringByteChannel.read(ByteBuffer[])
protected long read0(ByteBuffer[] dsts, int offset, int length) throws IOException
read0
in class StreamSourceFrameChannel
IOException
ScatteringByteChannel.read(ByteBuffer[], int, int)
protected final boolean isComplete()
StreamSourceFrameChannel
true
if the frame was complete.isComplete
in class StreamSourceFrameChannel
protected void afterRead(ByteBuffer buffer, int position, int length) throws IOException
ByteBuffer
buffer
- the ByteBuffer
into which the data was readposition
- the position it was written tolength
- the number of bytes there were writtenIOException
- thrown if an error accourprotected void complete() throws IOException
StreamSourceFrameChannel
complete
in class StreamSourceFrameChannel
IOException
Copyright © 2013 JBoss by Red Hat. All rights reserved.