public abstract class AbstractSourceConduit<D extends SourceConduit> extends AbstractConduit<D> implements SourceConduit
next
Modifier | Constructor and Description |
---|---|
protected |
AbstractSourceConduit(D next)
Construct a new instance.
|
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. |
getWorker
protected AbstractSourceConduit(D next)
next
- the delegate conduit to setpublic void terminateReads() throws IOException
SourceConduit
terminateReads
in interface SourceConduit
IOException
- if there was a problempublic boolean isReadShutdown()
SourceConduit
isReadShutdown
in interface SourceConduit
true
if writes are shut down, false
otherwisepublic void resumeReads()
SourceConduit
ReadReadyHandler
should be invoked as soon as data can be read
without blocking.resumeReads
in interface SourceConduit
public void suspendReads()
SourceConduit
ReadReadyHandler
should be suspended.suspendReads
in interface SourceConduit
public void wakeupReads()
SourceConduit
ReadReadyHandler
should be invoked immediately, and then again as soon
as data can be read without blocking.wakeupReads
in interface SourceConduit
public boolean isReadResumed()
SourceConduit
isReadResumed
in interface SourceConduit
true
if read notifications are enabledpublic void awaitReadable() throws IOException
SourceConduit
awaitReadable
in interface SourceConduit
InterruptedIOException
- if the operation is interrupted; the thread's interrupt flag will be set as wellIOException
- if an I/O error occurspublic void awaitReadable(long time, TimeUnit timeUnit) throws IOException
SourceConduit
awaitReadable
in interface SourceConduit
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 occurspublic XnioIoThread getReadThread()
SourceConduit
getReadThread
in interface SourceConduit
public void setReadReadyHandler(ReadReadyHandler handler)
SourceConduit
setReadReadyHandler
in interface SourceConduit
Copyright © 2017 JBoss by Red Hat. All rights reserved.