public interface SourceConduit extends Conduit
Modifier and Type | Method and Description |
---|---|
void |
awaitReadable()
Block until this channel becomes readable again.
|
void |
awaitReadable(long time,
TimeUnit timeUnit)
Block until this conduit becomes readable again, or until the timeout expires.
|
XnioIoThread |
getReadThread()
Get the XNIO read thread.
|
boolean |
isReadResumed()
Determine whether read notifications are currently enabled.
|
boolean |
isReadShutdown()
Determine whether reads have been shut down on this conduit.
|
void |
resumeReads()
Indicate that the conduit's
ReadReadyHandler should be invoked as soon as data can be read
without blocking. |
void |
setReadReadyHandler(ReadReadyHandler handler)
Set the handler which should receive readiness notifications.
|
void |
suspendReads()
Indicate that calling the conduit's
ReadReadyHandler should be suspended. |
void |
terminateReads()
Indicate that no more data will be read from this conduit.
|
void |
wakeupReads()
Indicate that the conduit's
ReadReadyHandler should be invoked immediately, and then again as soon
as data can be read without blocking. |
void terminateReads() throws IOException
IOException
- if there was a problemboolean isReadShutdown()
true
if writes are shut down, false
otherwisevoid resumeReads()
ReadReadyHandler
should be invoked as soon as data can be read
without blocking.void suspendReads()
ReadReadyHandler
should be suspended.void wakeupReads()
ReadReadyHandler
should be invoked immediately, and then again as soon
as data can be read without blocking.boolean isReadResumed()
true
if read notifications are enabledvoid 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 occursXnioIoThread getReadThread()
void setReadReadyHandler(ReadReadyHandler handler)
next
- the filter to receive readiness notificationsCopyright © 2021 JBoss by Red Hat. All rights reserved.