public interface SourceConduit extends Conduit
Modifier and Type | Method and Description |
---|---|
void |
awaitReadable()
Block until this channel becomes readable again.
|
void |
awaitReadable(long time,
java.util.concurrent.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 java.io.IOException
java.io.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 java.io.IOException
java.io.InterruptedIOException
- if the operation is interrupted; the thread's interrupt flag will be set as welljava.io.IOException
- if an I/O error occursvoid awaitReadable(long time, java.util.concurrent.TimeUnit timeUnit) throws java.io.IOException
time
- the time to waittimeUnit
- the time unitjava.io.InterruptedIOException
- if the operation is interrupted; the thread's interrupt flag will be set as welljava.io.IOException
- if an I/O error occursXnioIoThread getReadThread()
void setReadReadyHandler(ReadReadyHandler handler)
next
- the filter to receive readiness notificationsCopyright © 2016 JBoss, a division of Red Hat, Inc.