public class CompositeExtensionFunction extends Object implements ExtensionFunction
RSV1, RSV2, RSV3
Modifier and Type | Method and Description |
---|---|
static ExtensionFunction |
compose(ExtensionFunction... functions) |
static ExtensionFunction |
compose(List<ExtensionFunction> functions) |
void |
dispose()
Dispose this function.
|
boolean |
hasExtensionOpCode()
Validate if current extension defines a new WebSocket Opcode.
|
PooledByteBuffer |
transformForRead(PooledByteBuffer pooledBuffer,
StreamSourceFrameChannel channel,
boolean lastFragementOfMessage)
Transform the supplied buffer per this extension.
|
PooledByteBuffer |
transformForWrite(PooledByteBuffer pooledBuffer,
StreamSinkFrameChannel channel,
boolean lastFrame)
Transform the supplied buffer per this extension.
|
int |
writeRsv(int rsv)
Add RSV bits (RSV1, RSV2, RSV3) to the current rsv status.
|
public static ExtensionFunction compose(List<ExtensionFunction> functions)
public static ExtensionFunction compose(ExtensionFunction... functions)
public boolean hasExtensionOpCode()
ExtensionFunction
hasExtensionOpCode
in interface ExtensionFunction
true
if current extension defines specific Opcode
false
is current extension does not define specific Opcodepublic int writeRsv(int rsv)
ExtensionFunction
writeRsv
in interface ExtensionFunction
rsv
- current RSV bits statuspublic PooledByteBuffer transformForWrite(PooledByteBuffer pooledBuffer, StreamSinkFrameChannel channel, boolean lastFrame) throws IOException
ExtensionFunction
transformForWrite
in interface ExtensionFunction
pooledBuffer
- Buffer to transformchannel
- working channelIOException
public PooledByteBuffer transformForRead(PooledByteBuffer pooledBuffer, StreamSourceFrameChannel channel, boolean lastFragementOfMessage) throws IOException
ExtensionFunction
transformForRead
in interface ExtensionFunction
pooledBuffer
- Buffer to transformchannel
- working channellastFragementOfMessage
- If this frame is the last fragment of a message. Note that this may not be received for every message, if the message ends with an empty frameIOException
public void dispose()
ExtensionFunction
dispose
in interface ExtensionFunction
Copyright © 2017 JBoss by Red Hat. All rights reserved.