Package io.undertow.conduits
Class ReadTimeoutStreamSourceConduit
java.lang.Object
org.xnio.conduits.AbstractConduit<D>
org.xnio.conduits.AbstractSourceConduit<D>
org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>
io.undertow.conduits.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
-
Constructor Summary
ConstructorsConstructorDescriptionReadTimeoutStreamSourceConduit
(org.xnio.conduits.StreamSourceConduit delegate, org.xnio.StreamConnection connection, OpenListener openListener) -
Method Summary
Modifier and TypeMethodDescriptionvoid
void
awaitReadable
(long time, TimeUnit timeUnit) int
read
(ByteBuffer dst) long
read
(ByteBuffer[] dsts, int offset, int length) void
void
void
toString()
long
transferTo
(long position, long count, FileChannel target) long
transferTo
(long count, ByteBuffer throughBuffer, org.xnio.channels.StreamSinkChannel target) Methods inherited from class org.xnio.conduits.AbstractSourceConduit
getReadThread, isReadResumed, isReadShutdown, setReadReadyHandler, wakeupReads
Methods inherited from class org.xnio.conduits.AbstractConduit
getWorker
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface org.xnio.conduits.Conduit
getWorker
Methods inherited from interface org.xnio.conduits.SourceConduit
getReadThread, isReadResumed, isReadShutdown, setReadReadyHandler, wakeupReads
-
Constructor Details
-
ReadTimeoutStreamSourceConduit
public ReadTimeoutStreamSourceConduit(org.xnio.conduits.StreamSourceConduit delegate, org.xnio.StreamConnection connection, OpenListener openListener)
-
-
Method Details
-
transferTo
- Specified by:
transferTo
in interfaceorg.xnio.conduits.StreamSourceConduit
- Overrides:
transferTo
in classorg.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>
- Throws:
IOException
-
transferTo
public long transferTo(long count, ByteBuffer throughBuffer, org.xnio.channels.StreamSinkChannel target) throws IOException - Specified by:
transferTo
in interfaceorg.xnio.conduits.StreamSourceConduit
- Overrides:
transferTo
in classorg.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>
- Throws:
IOException
-
read
- Specified by:
read
in interfaceorg.xnio.conduits.StreamSourceConduit
- Overrides:
read
in classorg.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>
- Throws:
IOException
-
read
- Specified by:
read
in interfaceorg.xnio.conduits.StreamSourceConduit
- Overrides:
read
in classorg.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>
- Throws:
IOException
-
awaitReadable
- Specified by:
awaitReadable
in interfaceorg.xnio.conduits.SourceConduit
- Overrides:
awaitReadable
in classorg.xnio.conduits.AbstractSourceConduit<org.xnio.conduits.StreamSourceConduit>
- Throws:
IOException
-
awaitReadable
- Specified by:
awaitReadable
in interfaceorg.xnio.conduits.SourceConduit
- Overrides:
awaitReadable
in classorg.xnio.conduits.AbstractSourceConduit<org.xnio.conduits.StreamSourceConduit>
- Throws:
IOException
-
resumeReads
public void resumeReads()- Specified by:
resumeReads
in interfaceorg.xnio.conduits.SourceConduit
- Overrides:
resumeReads
in classorg.xnio.conduits.AbstractSourceConduit<org.xnio.conduits.StreamSourceConduit>
-
terminateReads
- Specified by:
terminateReads
in interfaceorg.xnio.conduits.SourceConduit
- Overrides:
terminateReads
in classorg.xnio.conduits.AbstractSourceConduit<org.xnio.conduits.StreamSourceConduit>
- Throws:
IOException
-
suspendReads
public void suspendReads()- Specified by:
suspendReads
in interfaceorg.xnio.conduits.SourceConduit
- Overrides:
suspendReads
in classorg.xnio.conduits.AbstractSourceConduit<org.xnio.conduits.StreamSourceConduit>
-
toString
-