Module 

Interface SourceConduit

    • Method Detail

      • terminateReads

        void terminateReads()
                     throws java.io.IOException
        Indicate that no more data will be read from this conduit. If unread data exists, an exception may be thrown.
        Throws:
        java.io.IOException - if there was a problem
      • isReadShutdown

        boolean isReadShutdown()
        Determine whether reads have been shut down on this conduit.
        Returns:
        true if writes are shut down, false otherwise
      • resumeReads

        void resumeReads()
        Indicate that the conduit's ReadReadyHandler should be invoked as soon as data can be read without blocking.
      • suspendReads

        void suspendReads()
        Indicate that calling the conduit's ReadReadyHandler should be suspended.
      • wakeupReads

        void wakeupReads()
        Indicate that the conduit's ReadReadyHandler should be invoked immediately, and then again as soon as data can be read without blocking.
      • isReadResumed

        boolean isReadResumed()
        Determine whether read notifications are currently enabled.
        Returns:
        true if read notifications are enabled
      • awaitReadable

        void awaitReadable()
                    throws java.io.IOException
        Block until this channel becomes readable again. This method may return spuriously before the channel becomes readable.
        Throws:
        java.io.InterruptedIOException - if the operation is interrupted; the thread's interrupt flag will be set as well
        java.io.IOException - if an I/O error occurs
      • awaitReadable

        void awaitReadable​(long time,
                           java.util.concurrent.TimeUnit timeUnit)
                    throws java.io.IOException
        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.
        Parameters:
        time - the time to wait
        timeUnit - the time unit
        Throws:
        java.io.InterruptedIOException - if the operation is interrupted; the thread's interrupt flag will be set as well
        java.io.IOException - if an I/O error occurs
      • getReadThread

        XnioIoThread getReadThread()
        Get the XNIO read thread.
        Returns:
        the XNIO read thread
      • setReadReadyHandler

        void setReadReadyHandler​(ReadReadyHandler handler)
        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.
        Parameters:
        next - the filter to receive readiness notifications