public final class EmptyStreamSourceConduit extends Object implements org.xnio.conduits.StreamSourceConduit
Constructor and Description |
---|
EmptyStreamSourceConduit(org.xnio.XnioIoThread readThread) Construct a new instance. |
Modifier and Type | Method and Description |
---|---|
void | awaitReadable() |
void | awaitReadable(long time, TimeUnit timeUnit) |
org.xnio.XnioIoThread | getReadThread() |
org.xnio.XnioWorker | getWorker() |
boolean | isReadResumed() |
boolean | isReadShutdown() |
int | read(ByteBuffer dst) |
long | read(ByteBuffer[] dsts, int offs, int len) |
void | resumeReads() |
void | setReadReadyHandler(org.xnio.conduits.ReadReadyHandler handler) |
void | suspendReads() |
void | terminateReads() |
long | transferTo(long count, ByteBuffer throughBuffer, org.xnio.channels.StreamSinkChannel target) |
long | transferTo(long position, long count, FileChannel target) |
void | wakeupReads() |
public EmptyStreamSourceConduit(org.xnio.XnioIoThread readThread)
readThread
- the read thread for this conduitpublic void setReadReadyHandler(org.xnio.conduits.ReadReadyHandler handler)
setReadReadyHandler
in interface org.xnio.conduits.SourceConduit
public long transferTo(long position, long count, FileChannel target) throws IOException
transferTo
in interface org.xnio.conduits.StreamSourceConduit
IOException
public long transferTo(long count, ByteBuffer throughBuffer, org.xnio.channels.StreamSinkChannel target) throws IOException
transferTo
in interface org.xnio.conduits.StreamSourceConduit
IOException
public int read(ByteBuffer dst) throws IOException
read
in interface org.xnio.conduits.StreamSourceConduit
IOException
public long read(ByteBuffer[] dsts, int offs, int len) throws IOException
read
in interface org.xnio.conduits.StreamSourceConduit
IOException
public boolean isReadShutdown()
isReadShutdown
in interface org.xnio.conduits.SourceConduit
public void resumeReads()
resumeReads
in interface org.xnio.conduits.SourceConduit
public void suspendReads()
suspendReads
in interface org.xnio.conduits.SourceConduit
public void wakeupReads()
wakeupReads
in interface org.xnio.conduits.SourceConduit
public boolean isReadResumed()
isReadResumed
in interface org.xnio.conduits.SourceConduit
public void awaitReadable() throws IOException
awaitReadable
in interface org.xnio.conduits.SourceConduit
IOException
public void awaitReadable(long time, TimeUnit timeUnit) throws IOException
awaitReadable
in interface org.xnio.conduits.SourceConduit
IOException
public void terminateReads() throws IOException
terminateReads
in interface org.xnio.conduits.SourceConduit
IOException
public org.xnio.XnioIoThread getReadThread()
getReadThread
in interface org.xnio.conduits.SourceConduit
public org.xnio.XnioWorker getWorker()
getWorker
in interface org.xnio.conduits.Conduit
Copyright © 2020 JBoss by Red Hat. All rights reserved.