public final class ReadTimeoutStreamSourceConduit
extends org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>
Options.READ_TIMEOUT
Constructor and Description |
---|
ReadTimeoutStreamSourceConduit(org.xnio.conduits.StreamSourceConduit delegate, org.xnio.StreamConnection connection, OpenListener openListener) |
Modifier and Type | Method and Description |
---|---|
void | awaitReadable() |
void | awaitReadable(long time, TimeUnit timeUnit) |
int | read(ByteBuffer dst) |
long | read(ByteBuffer[] dsts, int offset, int length) |
void | resumeReads() |
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() |
getReadThread, isReadResumed, isReadShutdown, setReadReadyHandler
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public ReadTimeoutStreamSourceConduit(org.xnio.conduits.StreamSourceConduit delegate, org.xnio.StreamConnection connection, OpenListener openListener)
public long transferTo(long position, long count, FileChannel target) throws IOException
transferTo
in interface org.xnio.conduits.StreamSourceConduit
transferTo
in class org.xnio.conduits.AbstractStreamSourceConduit<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
transferTo
in class org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>
IOException
public long read(ByteBuffer[] dsts, int offset, int length) throws IOException
read
in interface org.xnio.conduits.StreamSourceConduit
read
in class org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>
IOException
public int read(ByteBuffer dst) throws IOException
read
in interface org.xnio.conduits.StreamSourceConduit
read
in class org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>
IOException
public void awaitReadable() throws IOException
awaitReadable
in interface org.xnio.conduits.SourceConduit
awaitReadable
in class org.xnio.conduits.AbstractSourceConduit<org.xnio.conduits.StreamSourceConduit>
IOException
public void awaitReadable(long time, TimeUnit timeUnit) throws IOException
awaitReadable
in interface org.xnio.conduits.SourceConduit
awaitReadable
in class org.xnio.conduits.AbstractSourceConduit<org.xnio.conduits.StreamSourceConduit>
IOException
public void terminateReads() throws IOException
terminateReads
in interface org.xnio.conduits.SourceConduit
terminateReads
in class org.xnio.conduits.AbstractSourceConduit<org.xnio.conduits.StreamSourceConduit>
IOException
public void resumeReads()
resumeReads
in interface org.xnio.conduits.SourceConduit
resumeReads
in class org.xnio.conduits.AbstractSourceConduit<org.xnio.conduits.StreamSourceConduit>
public void suspendReads()
suspendReads
in interface org.xnio.conduits.SourceConduit
suspendReads
in class org.xnio.conduits.AbstractSourceConduit<org.xnio.conduits.StreamSourceConduit>
public void wakeupReads()
wakeupReads
in interface org.xnio.conduits.SourceConduit
wakeupReads
in class org.xnio.conduits.AbstractSourceConduit<org.xnio.conduits.StreamSourceConduit>
Copyright © 2020 JBoss by Red Hat. All rights reserved.