public interface SuspendableReadChannel extends CloseableChannel
EMPTY
Modifier and Type | Method and Description |
---|---|
void |
awaitReadable()
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.
|
ChannelListener.Setter<? extends SuspendableReadChannel> |
getCloseSetter()
Get the setter which can be used to change the close listener for this channel.
|
ChannelListener.Setter<? extends SuspendableReadChannel> |
getReadSetter()
Get the setter which can be used to change the read listener for this channel.
|
XnioExecutor |
getReadThread()
Deprecated.
The
CloseableChannel.getIoThread() method should be used instead. |
boolean |
isReadResumed()
Determine whether reads are resumed.
|
void |
resumeReads()
Resume reads on this channel.
|
void |
shutdownReads()
Places this readable channel at "end of stream".
|
void |
suspendReads()
Suspend further read notifications on this channel.
|
void |
wakeupReads()
Deprecated.
Users should instead submit
Runnable tasks to the channel thread when this functionality is needed. |
close, getIoThread, getWorker
getOption, setOption, supportsOption
void suspendReads()
void resumeReads()
boolean isReadResumed()
true
if reads are resumed, false
if reads are suspended@Deprecated void wakeupReads()
Runnable
tasks to the channel thread when this functionality is needed.Resume reads
on this channel, and force the read listener to be triggered even if the
channel isn't actually readable.void shutdownReads() throws IOException
CloseableChannel.close()
to be called automatically.IOException
- if an I/O error occursvoid awaitReadable() throws IOException
InterruptedIOException
- if the operation is interrupted; the thread's interrupt flag will be set as wellIOException
- if an I/O error occursvoid awaitReadable(long time, TimeUnit timeUnit) throws IOException
time
- the time to waittimeUnit
- the time unitInterruptedIOException
- if the operation is interrupted; the thread's interrupt flag will be set as wellIOException
- if an I/O error occurs@Deprecated XnioExecutor getReadThread()
CloseableChannel.getIoThread()
method should be used instead.null
if none is configured or availableChannelListener.Setter<? extends SuspendableReadChannel> getReadSetter()
ChannelListener.Setter<? extends SuspendableReadChannel> getCloseSetter()
getCloseSetter
in interface CloseableChannel
Copyright © 2016 JBoss by Red Hat. All rights reserved.