Package io.undertow.conduits
Class EmptyStreamSourceConduit
java.lang.Object
io.undertow.conduits.EmptyStreamSourceConduit
- All Implemented Interfaces:
org.xnio.conduits.Conduit
,org.xnio.conduits.SourceConduit
,org.xnio.conduits.StreamSourceConduit
public final class EmptyStreamSourceConduit
extends Object
implements org.xnio.conduits.StreamSourceConduit
A stream source conduit which is always empty.
Temporary copy from XNIO, see https://issues.jboss.org/browse/XNIO-199
- Author:
- David M. Lloyd
-
Constructor Summary
ConstructorsConstructorDescriptionEmptyStreamSourceConduit
(org.xnio.XnioIoThread readThread) Construct a new instance. -
Method Summary
Modifier and TypeMethodDescriptionvoid
void
awaitReadable
(long time, TimeUnit timeUnit) org.xnio.XnioIoThread
org.xnio.XnioWorker
boolean
boolean
int
read
(ByteBuffer dst) long
read
(ByteBuffer[] dsts, int offs, int len) void
void
setReadReadyHandler
(org.xnio.conduits.ReadReadyHandler handler) void
void
long
transferTo
(long position, long count, FileChannel target) long
transferTo
(long count, ByteBuffer throughBuffer, org.xnio.channels.StreamSinkChannel target) void
-
Constructor Details
-
EmptyStreamSourceConduit
public EmptyStreamSourceConduit(org.xnio.XnioIoThread readThread) Construct a new instance.- Parameters:
readThread
- the read thread for this conduit
-
-
Method Details
-
setReadReadyHandler
public void setReadReadyHandler(org.xnio.conduits.ReadReadyHandler handler) - Specified by:
setReadReadyHandler
in interfaceorg.xnio.conduits.SourceConduit
-
transferTo
- Specified by:
transferTo
in interfaceorg.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
- Throws:
IOException
-
read
- Specified by:
read
in interfaceorg.xnio.conduits.StreamSourceConduit
- Throws:
IOException
-
read
- Specified by:
read
in interfaceorg.xnio.conduits.StreamSourceConduit
- Throws:
IOException
-
isReadShutdown
public boolean isReadShutdown()- Specified by:
isReadShutdown
in interfaceorg.xnio.conduits.SourceConduit
-
resumeReads
public void resumeReads()- Specified by:
resumeReads
in interfaceorg.xnio.conduits.SourceConduit
-
suspendReads
public void suspendReads()- Specified by:
suspendReads
in interfaceorg.xnio.conduits.SourceConduit
-
wakeupReads
public void wakeupReads()- Specified by:
wakeupReads
in interfaceorg.xnio.conduits.SourceConduit
-
isReadResumed
public boolean isReadResumed()- Specified by:
isReadResumed
in interfaceorg.xnio.conduits.SourceConduit
-
awaitReadable
- Specified by:
awaitReadable
in interfaceorg.xnio.conduits.SourceConduit
- Throws:
IOException
-
awaitReadable
- Specified by:
awaitReadable
in interfaceorg.xnio.conduits.SourceConduit
- Throws:
IOException
-
terminateReads
- Specified by:
terminateReads
in interfaceorg.xnio.conduits.SourceConduit
- Throws:
IOException
-
getReadThread
public org.xnio.XnioIoThread getReadThread()- Specified by:
getReadThread
in interfaceorg.xnio.conduits.SourceConduit
-
getWorker
public org.xnio.XnioWorker getWorker()- Specified by:
getWorker
in interfaceorg.xnio.conduits.Conduit
-