Package org.xnio.channels
Class AssembledMessageChannel
java.lang.Object
org.xnio.channels.AssembledMessageChannel
- All Implemented Interfaces:
Closeable
,AutoCloseable
,Channel
,InterruptibleChannel
,CloseableChannel
,Configurable
,MessageChannel
,ReadableMessageChannel
,SuspendableChannel
,SuspendableReadChannel
,SuspendableWriteChannel
,WritableMessageChannel
- Direct Known Subclasses:
AssembledConnectedMessageChannel
A bidirectional message channel assembled from a readable and writable message channel.
- Author:
- David M. Lloyd
-
Field Summary
Fields inherited from interface org.xnio.channels.Configurable
EMPTY
-
Constructor Summary
ConstructorsConstructorDescriptionAssembledMessageChannel
(CloseableChannel closeable, ReadableMessageChannel readable, WritableMessageChannel writable) Construct a new instance.AssembledMessageChannel
(ReadableMessageChannel readable, WritableMessageChannel writable) Construct a new instance. -
Method Summary
Modifier and TypeMethodDescriptionvoid
Block until this channel becomes readable again.void
awaitReadable
(long time, TimeUnit timeUnit) Block until this channel becomes readable again, or until the timeout expires.void
Block until this channel becomes writable again.void
awaitWritable
(long time, TimeUnit timeUnit) Block until this channel becomes writable again, or until the timeout expires.void
close()
Close this channel.boolean
flush()
Flush any waiting partial send or write.ChannelListener.Setter
<? extends AssembledMessageChannel> Get the setter which can be used to change the close listener for this channel.Get the I/O thread associated with this channel.<T> T
Get the value of a channel option.ChannelListener.Setter
<? extends AssembledMessageChannel> Get the setter which can be used to change the read listener for this channel.Deprecated.Get the worker for this channel.ChannelListener.Setter
<? extends AssembledMessageChannel> Get the setter which can be used to change the write listener for this channel.Deprecated.boolean
isOpen()
Determine whether this channel is open.boolean
Determine whether reads are resumed.boolean
Determine whether writes are resumed.int
receive
(ByteBuffer buffer) Receive a message.long
receive
(ByteBuffer[] buffers) Receive a message.long
receive
(ByteBuffer[] buffers, int offs, int len) Receive a message.void
Resume reads on this channel.void
Resume writes on this channel.boolean
send
(ByteBuffer buffer) Send a complete message.boolean
send
(ByteBuffer[] buffers) Send a complete message.boolean
send
(ByteBuffer[] buffers, int offs, int len) Send a complete message.boolean
sendFinal
(ByteBuffer buffer) Send a complete message.boolean
sendFinal
(ByteBuffer[] buffers) Send a complete message.boolean
sendFinal
(ByteBuffer[] buffers, int offs, int len) Send a complete message.<T> T
Set an option for this channel.void
Places this readable channel at "end of stream".void
Indicate that writing is complete for this channel.boolean
supportsOption
(Option<?> option) Determine whether an option is supported on this channel.void
Suspend further read notifications on this channel.void
Suspend further write notifications on this channel.void
Resume reads
on this channel, and force the read listener to be triggered even if the channel isn't actually readable.void
Resume writes
on this channel, and force the write listener to be triggered even if the channel isn't actually writable.
-
Constructor Details
-
AssembledMessageChannel
public AssembledMessageChannel(CloseableChannel closeable, ReadableMessageChannel readable, WritableMessageChannel writable) Construct a new instance.- Parameters:
closeable
- the single central closeable channelreadable
- the read channelwritable
- the write channel
-
AssembledMessageChannel
Construct a new instance.- Parameters:
readable
- the read channelwritable
- the write channel
-
-
Method Details
-
getIoThread
Description copied from interface:CloseableChannel
Get the I/O thread associated with this channel.- Specified by:
getIoThread
in interfaceCloseableChannel
- Returns:
- the I/O thread associated with this channel
-
getReadSetter
Description copied from interface:MessageChannel
Get the setter which can be used to change the read listener for this channel.- Specified by:
getReadSetter
in interfaceMessageChannel
- Specified by:
getReadSetter
in interfaceReadableMessageChannel
- Specified by:
getReadSetter
in interfaceSuspendableChannel
- Specified by:
getReadSetter
in interfaceSuspendableReadChannel
- Returns:
- the setter
-
suspendReads
public void suspendReads()Description copied from interface:SuspendableReadChannel
Suspend further read notifications on this channel.- Specified by:
suspendReads
in interfaceSuspendableReadChannel
-
resumeReads
public void resumeReads()Description copied from interface:SuspendableReadChannel
Resume reads on this channel. The read listener will be called as soon as there is data available to be read.- Specified by:
resumeReads
in interfaceSuspendableReadChannel
-
isReadResumed
public boolean isReadResumed()Description copied from interface:SuspendableReadChannel
Determine whether reads are resumed.- Specified by:
isReadResumed
in interfaceSuspendableReadChannel
- Returns:
true
if reads are resumed,false
if reads are suspended
-
wakeupReads
public void wakeupReads()Description copied from interface:SuspendableReadChannel
Resume reads
on this channel, and force the read listener to be triggered even if the channel isn't actually readable.- Specified by:
wakeupReads
in interfaceSuspendableReadChannel
-
shutdownReads
Description copied from interface:SuspendableReadChannel
Places this readable channel at "end of stream". Further reads will result in EOF. Shutting down all directions of a channel will causeCloseableChannel.close()
to be called automatically.- Specified by:
shutdownReads
in interfaceSuspendableReadChannel
- Throws:
IOException
- if an I/O error occurs
-
awaitReadable
Description copied from interface:SuspendableReadChannel
Block until this channel becomes readable again. This method may return spuriously before the channel becomes readable.- Specified by:
awaitReadable
in interfaceSuspendableReadChannel
- Throws:
IOException
- if an I/O error occurs
-
awaitReadable
Description copied from interface:SuspendableReadChannel
Block until this channel becomes readable again, or until the timeout expires. This method may return spuriously before the channel becomes readable or the timeout expires.- Specified by:
awaitReadable
in interfaceSuspendableReadChannel
- Parameters:
time
- the time to waittimeUnit
- the time unit- Throws:
IOException
- if an I/O error occurs
-
getReadThread
Deprecated.Description copied from interface:SuspendableReadChannel
Get the read thread for this channel.- Specified by:
getReadThread
in interfaceSuspendableReadChannel
- Returns:
- the thread, or
null
if none is configured or available
-
receive
Description copied from interface:ReadableMessageChannel
Receive a message.- Specified by:
receive
in interfaceReadableMessageChannel
- Parameters:
buffer
- the buffer that will hold the message- Returns:
- the size of the received message, 0 if no message is available, and -1 if the message channel has reached an end-of-file condition
- Throws:
IOException
- if an I/O error occurs
-
receive
Description copied from interface:ReadableMessageChannel
Receive a message.- Specified by:
receive
in interfaceReadableMessageChannel
- Parameters:
buffers
- the buffers that will hold the message- Returns:
- the size of the received message, 0 if no message is available, and -1 if the message channel has reached an end-of-file condition
- Throws:
IOException
- if an I/O error occurs
-
receive
Description copied from interface:ReadableMessageChannel
Receive a message.- Specified by:
receive
in interfaceReadableMessageChannel
- Parameters:
buffers
- the buffers that will hold the messageoffs
- the offset into the array of buffers of the first buffer to read intolen
- the number of buffers to fill- Returns:
- the size of the received message, 0 if no message is available, and -1 if the message channel has reached an end-of-file condition
- Throws:
IOException
- if an I/O error occurs
-
getWriteSetter
Description copied from interface:MessageChannel
Get the setter which can be used to change the write listener for this channel.- Specified by:
getWriteSetter
in interfaceMessageChannel
- Specified by:
getWriteSetter
in interfaceSuspendableChannel
- Specified by:
getWriteSetter
in interfaceSuspendableWriteChannel
- Specified by:
getWriteSetter
in interfaceWritableMessageChannel
- Returns:
- the setter
-
suspendWrites
public void suspendWrites()Description copied from interface:SuspendableWriteChannel
Suspend further write notifications on this channel.- Specified by:
suspendWrites
in interfaceSuspendableWriteChannel
-
resumeWrites
public void resumeWrites()Description copied from interface:SuspendableWriteChannel
Resume writes on this channel. The write listener will be called as soon as the channel becomes writable.- Specified by:
resumeWrites
in interfaceSuspendableWriteChannel
-
isWriteResumed
public boolean isWriteResumed()Description copied from interface:SuspendableWriteChannel
Determine whether writes are resumed.- Specified by:
isWriteResumed
in interfaceSuspendableWriteChannel
- Returns:
true
if writes are resumed,false
if writes are suspended
-
wakeupWrites
public void wakeupWrites()Description copied from interface:SuspendableWriteChannel
Resume writes
on this channel, and force the write listener to be triggered even if the channel isn't actually writable.- Specified by:
wakeupWrites
in interfaceSuspendableWriteChannel
-
shutdownWrites
Description copied from interface:SuspendableWriteChannel
Indicate that writing is complete for this channel. Further attempts to write data to this channel after this method is invoked will result in an exception. If this method was already called, calling this method again will have no additional effect. After this method is called, any remaining data still must be flushed out via theSuspendableWriteChannel.flush()
method; once this is done, if the read side of the channel was shut down, the channel will automatically close.- Specified by:
shutdownWrites
in interfaceSuspendableWriteChannel
- Throws:
IOException
- if an I/O error occurs
-
awaitWritable
Description copied from interface:SuspendableWriteChannel
Block until this channel becomes writable again. This method may return spuriously before the channel becomes writable.- Specified by:
awaitWritable
in interfaceSuspendableWriteChannel
- Throws:
IOException
- if an I/O error occurs
-
awaitWritable
Description copied from interface:SuspendableWriteChannel
Block until this channel becomes writable again, or until the timeout expires. This method may return spuriously before the channel becomes writable or the timeout expires.- Specified by:
awaitWritable
in interfaceSuspendableWriteChannel
- Parameters:
time
- the time to waittimeUnit
- the time unit- Throws:
IOException
- if an I/O error occurs
-
getWriteThread
Deprecated.Description copied from interface:SuspendableWriteChannel
Get the write thread for this channel.- Specified by:
getWriteThread
in interfaceSuspendableWriteChannel
- Returns:
- the thread, or
null
if none is configured or available
-
send
Description copied from interface:WritableMessageChannel
Send a complete message.- Specified by:
send
in interfaceWritableMessageChannel
- Parameters:
buffer
- the message to send- Returns:
- the result of the send operation;
true
if the message was sent, orfalse
if it would block - Throws:
IOException
- if an I/O error occurs
-
send
Description copied from interface:WritableMessageChannel
Send a complete message.- Specified by:
send
in interfaceWritableMessageChannel
- Parameters:
buffers
- the buffers holding the message to send- Returns:
- the result of the send operation;
true
if the message was sent, orfalse
if it would block - Throws:
IOException
- if an I/O error occurs
-
send
Description copied from interface:WritableMessageChannel
Send a complete message.- Specified by:
send
in interfaceWritableMessageChannel
- Parameters:
buffers
- the buffers holding the message to sendoffs
- the offset into the buffer array of the first bufferlen
- the number of buffers that contain data to send- Returns:
- the result of the send operation;
true
if the message was sent, orfalse
if it would block - Throws:
IOException
- if an I/O error occurs
-
sendFinal
Description copied from interface:WritableMessageChannel
Send a complete message. If the message was successfully sent the channel with have its writes shutdown.- Specified by:
sendFinal
in interfaceWritableMessageChannel
- Parameters:
buffer
- the message to send- Returns:
- the result of the send operation;
true
if the message was sent, orfalse
if it would block - Throws:
IOException
- if an I/O error occurs
-
sendFinal
Description copied from interface:WritableMessageChannel
Send a complete message. If the message was successfully sent the channel with have its writes shutdown.- Specified by:
sendFinal
in interfaceWritableMessageChannel
- Parameters:
buffers
- the buffers holding the message to send- Returns:
- the result of the send operation;
true
if the message was sent, orfalse
if it would block - Throws:
IOException
- if an I/O error occurs
-
sendFinal
Description copied from interface:WritableMessageChannel
Send a complete message. If the message was successfully sent the channel with have its writes shutdown.- Specified by:
sendFinal
in interfaceWritableMessageChannel
- Parameters:
buffers
- the buffers holding the message to sendoffs
- the offset into the buffer array of the first bufferlen
- the number of buffers that contain data to send- Returns:
- the result of the send operation;
true
if the message was sent, orfalse
if it would block - Throws:
IOException
- if an I/O error occurs
-
flush
Description copied from interface:SuspendableWriteChannel
Flush any waiting partial send or write. If there is no data to flush, or if the flush completed successfully, this method will returntrue
. If there is data to flush which cannot be immediately written, this method will returnfalse
. If this method returnstrue
afterSuspendableWriteChannel.shutdownWrites()
was called on this channel, the write listener will no longer be invoked on this channel. If this is case and additionally this is a write-only channel or the read side was previously shut down, then the channel will automatically be closed.- Specified by:
flush
in interfaceSuspendableWriteChannel
- Returns:
true
if the message was flushed, orfalse
if the result would block- Throws:
IOException
- if an I/O error occurs
-
getCloseSetter
Description copied from interface:MessageChannel
Get the setter which can be used to change the close listener for this channel. If the channel is already closed, then the listener will not be called.- Specified by:
getCloseSetter
in interfaceCloseableChannel
- Specified by:
getCloseSetter
in interfaceMessageChannel
- Specified by:
getCloseSetter
in interfaceReadableMessageChannel
- Specified by:
getCloseSetter
in interfaceSuspendableChannel
- Specified by:
getCloseSetter
in interfaceSuspendableReadChannel
- Specified by:
getCloseSetter
in interfaceSuspendableWriteChannel
- Specified by:
getCloseSetter
in interfaceWritableMessageChannel
- Returns:
- the setter
-
getWorker
Description copied from interface:CloseableChannel
Get the worker for this channel.- Specified by:
getWorker
in interfaceCloseableChannel
- Returns:
- the worker
-
close
Description copied from interface:CloseableChannel
Close this channel. When a channel is closed, its close listener is invoked. Invoking this method more than once has no additional effect.- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceChannel
- Specified by:
close
in interfaceCloseable
- Specified by:
close
in interfaceCloseableChannel
- Specified by:
close
in interfaceInterruptibleChannel
- Specified by:
close
in interfaceSuspendableWriteChannel
- Throws:
IOException
- if the close failed
-
isOpen
public boolean isOpen()Description copied from interface:SuspendableWriteChannel
Determine whether this channel is open. This method will returnfalse
if all directions are shut down, even if there is unflushed write data pending.- Specified by:
isOpen
in interfaceChannel
- Specified by:
isOpen
in interfaceSuspendableWriteChannel
- Returns:
true
if the channel is open,false
otherwise
-
supportsOption
Description copied from interface:Configurable
Determine whether an option is supported on this channel.- Specified by:
supportsOption
in interfaceConfigurable
- Parameters:
option
- the option- Returns:
true
if it is supported
-
getOption
Description copied from interface:Configurable
Get the value of a channel option.- Specified by:
getOption
in interfaceConfigurable
- Type Parameters:
T
- the type of the option value- Parameters:
option
- the option to get- Returns:
- the value of the option, or
null
if it is not set - Throws:
IOException
- if an I/O error occurred when reading the option
-
setOption
Description copied from interface:Configurable
Set an option for this channel. Unsupported options are ignored.- Specified by:
setOption
in interfaceConfigurable
- Type Parameters:
T
- the type of the option value- Parameters:
option
- the option to setvalue
- the value of the option to set- Returns:
- the previous option value, if any
- Throws:
IllegalArgumentException
- if the value is not acceptable for this optionIOException
- if an I/O error occurred when modifying the option
-