| Access | Constructor and Description |
|---|---|
| protected | AbstractSynchronizedSourceConduit(final D
the next conduit in the chain next)Construct a new instance. |
| protected | AbstractSynchronizedSourceConduit(final D
the next conduit in the chain next, final Object the lock object to use lock)Construct a new instance. |
| Modifier and Type | Method and Description |
|---|---|
| public void | awaitReadable()
Implements org. Block until this channel becomes readable again. |
| public void | awaitReadable(final long
the time to wait time, final TimeUnit the time unit timeUnit)Implements org. Block until this conduit becomes readable again, or until the timeout expires. |
| public XnioIoThread | |
| public boolean | isReadResumed()
Implements org. Determine whether read notifications are currently enabled. |
| public boolean | isReadShutdown()
Implements org. Determine whether reads have been shut down on this conduit. |
| public void | resumeReads()
Implements org. Indicate that the conduit's |
| public void | setReadReadyHandler(final ReadReadyHandler
the filter to receive readiness notifications handler)Implements org. Set the handler which should receive readiness notifications. |
| public void | suspendReads()
Implements org. Indicate that calling the conduit's |
| public void | terminateReads()
Implements org. Indicate that no more data will be read from this conduit. |
| public void | wakeupReads()
Implements org. Indicate that the conduit's |
| AbstractSynchronizedSourceConduit | back to summary |
|---|---|
| protected AbstractSynchronizedSourceConduit(final D next) Construct a new instance. A new lock object is created.
| |
| AbstractSynchronizedSourceConduit | back to summary |
|---|---|
| protected AbstractSynchronizedSourceConduit(final D next, final Object lock) Construct a new instance.
| |
| awaitReadable | back to summary |
|---|---|
| public void awaitReadable() throws IOException Implements org. Doc from org. Block until this channel becomes readable again. This method may return spuriously before the channel becomes readable.
| |
| awaitReadable | back to summary |
|---|---|
| public void awaitReadable(final long time, final TimeUnit timeUnit) throws IOException Implements org. Doc from org. Block until this conduit becomes readable again, or until the timeout expires. This method may return spuriously before the conduit becomes readable or the timeout expires.
| |
| getReadThread | back to summary |
|---|---|
| public XnioIoThread getReadThread() Implements org. Doc from org. Get the XNIO read thread.
| |
| isReadResumed | back to summary |
|---|---|
| public boolean isReadResumed() Implements org. Doc from org. Determine whether read notifications are currently enabled.
| |
| isReadShutdown | back to summary |
|---|---|
| public boolean isReadShutdown() Implements org. Doc from org. Determine whether reads have been shut down on this conduit.
| |
| resumeReads | back to summary |
|---|---|
| public void resumeReads() Implements org. Doc from org. Indicate that the conduit's | |
| setReadReadyHandler | back to summary |
|---|---|
| public void setReadReadyHandler(final ReadReadyHandler handler) Implements org. Doc from org. Set the handler which should receive readiness notifications. A filter may pass this invocation on to the filter it wraps, or it may substitute itself.
| |
| suspendReads | back to summary |
|---|---|
| public void suspendReads() Implements org. Doc from org. Indicate that calling the conduit's | |
| terminateReads | back to summary |
|---|---|
| public void terminateReads() throws IOException Implements org. Doc from org. Indicate that no more data will be read from this conduit. If unread data exists, an exception may be thrown.
| |
| wakeupReads | back to summary |
|---|---|
| public void wakeupReads() Implements org. Doc from org. Indicate that the conduit's | |