Class ReadTimeoutStreamSourceConduit

  • All Implemented Interfaces:
    org.xnio.conduits.Conduit, org.xnio.conduits.SourceConduit, org.xnio.conduits.StreamSourceConduit

    public final class ReadTimeoutStreamSourceConduit
    extends org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>
    Wrapper for read timeout. This should always be the first wrapper applied to the underlying channel.
    Author:
    Stuart Douglas
    See Also:
    Options.READ_TIMEOUT
    • Field Summary

      • Fields inherited from class org.xnio.conduits.AbstractConduit

        next
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void awaitReadable()  
      void awaitReadable​(long time, java.util.concurrent.TimeUnit timeUnit)  
      int read​(java.nio.ByteBuffer dst)  
      long read​(java.nio.ByteBuffer[] dsts, int offset, int length)  
      void resumeReads()  
      void suspendReads()  
      void terminateReads()  
      long transferTo​(long position, long count, java.nio.channels.FileChannel target)  
      long transferTo​(long count, java.nio.ByteBuffer throughBuffer, org.xnio.channels.StreamSinkChannel target)  
      void wakeupReads()  
      • Methods inherited from class org.xnio.conduits.AbstractSourceConduit

        getReadThread, isReadResumed, isReadShutdown, setReadReadyHandler
      • Methods inherited from class org.xnio.conduits.AbstractConduit

        getWorker
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
      • Methods inherited from interface org.xnio.conduits.Conduit

        getWorker
      • Methods inherited from interface org.xnio.conduits.SourceConduit

        getReadThread, isReadResumed, isReadShutdown, setReadReadyHandler
    • Constructor Detail

      • ReadTimeoutStreamSourceConduit

        public ReadTimeoutStreamSourceConduit​(org.xnio.conduits.StreamSourceConduit delegate,
                                              org.xnio.StreamConnection connection,
                                              OpenListener openListener)
    • Method Detail

      • transferTo

        public long transferTo​(long position,
                               long count,
                               java.nio.channels.FileChannel target)
                        throws java.io.IOException
        Specified by:
        transferTo in interface org.xnio.conduits.StreamSourceConduit
        Overrides:
        transferTo in class org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>
        Throws:
        java.io.IOException
      • transferTo

        public long transferTo​(long count,
                               java.nio.ByteBuffer throughBuffer,
                               org.xnio.channels.StreamSinkChannel target)
                        throws java.io.IOException
        Specified by:
        transferTo in interface org.xnio.conduits.StreamSourceConduit
        Overrides:
        transferTo in class org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>
        Throws:
        java.io.IOException
      • read

        public long read​(java.nio.ByteBuffer[] dsts,
                         int offset,
                         int length)
                  throws java.io.IOException
        Specified by:
        read in interface org.xnio.conduits.StreamSourceConduit
        Overrides:
        read in class org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>
        Throws:
        java.io.IOException
      • read

        public int read​(java.nio.ByteBuffer dst)
                 throws java.io.IOException
        Specified by:
        read in interface org.xnio.conduits.StreamSourceConduit
        Overrides:
        read in class org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>
        Throws:
        java.io.IOException
      • awaitReadable

        public void awaitReadable()
                           throws java.io.IOException
        Specified by:
        awaitReadable in interface org.xnio.conduits.SourceConduit
        Overrides:
        awaitReadable in class org.xnio.conduits.AbstractSourceConduit<org.xnio.conduits.StreamSourceConduit>
        Throws:
        java.io.IOException
      • awaitReadable

        public void awaitReadable​(long time,
                                  java.util.concurrent.TimeUnit timeUnit)
                           throws java.io.IOException
        Specified by:
        awaitReadable in interface org.xnio.conduits.SourceConduit
        Overrides:
        awaitReadable in class org.xnio.conduits.AbstractSourceConduit<org.xnio.conduits.StreamSourceConduit>
        Throws:
        java.io.IOException
      • terminateReads

        public void terminateReads()
                            throws java.io.IOException
        Specified by:
        terminateReads in interface org.xnio.conduits.SourceConduit
        Overrides:
        terminateReads in class org.xnio.conduits.AbstractSourceConduit<org.xnio.conduits.StreamSourceConduit>
        Throws:
        java.io.IOException
      • resumeReads

        public void resumeReads()
        Specified by:
        resumeReads in interface org.xnio.conduits.SourceConduit
        Overrides:
        resumeReads in class org.xnio.conduits.AbstractSourceConduit<org.xnio.conduits.StreamSourceConduit>
      • suspendReads

        public void suspendReads()
        Specified by:
        suspendReads in interface org.xnio.conduits.SourceConduit
        Overrides:
        suspendReads in class org.xnio.conduits.AbstractSourceConduit<org.xnio.conduits.StreamSourceConduit>
      • wakeupReads

        public void wakeupReads()
        Specified by:
        wakeupReads in interface org.xnio.conduits.SourceConduit
        Overrides:
        wakeupReads in class org.xnio.conduits.AbstractSourceConduit<org.xnio.conduits.StreamSourceConduit>