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, setReadReadyHandlerclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitpublic 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.StreamSourceConduittransferTo in class org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>IOExceptionpublic long transferTo(long count,
ByteBuffer throughBuffer,
org.xnio.channels.StreamSinkChannel target)
throws IOException transferTo in interface org.xnio.conduits.StreamSourceConduittransferTo in class org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>IOExceptionpublic long read(ByteBuffer[] dsts, int offset, int length) throws IOException
read in interface org.xnio.conduits.StreamSourceConduitread in class org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>IOExceptionpublic int read(ByteBuffer dst) throws IOException
read in interface org.xnio.conduits.StreamSourceConduitread in class org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>IOExceptionpublic void awaitReadable()
throws IOException awaitReadable in interface org.xnio.conduits.SourceConduitawaitReadable in class org.xnio.conduits.AbstractSourceConduit<org.xnio.conduits.StreamSourceConduit>IOExceptionpublic void awaitReadable(long time,
TimeUnit timeUnit)
throws IOException awaitReadable in interface org.xnio.conduits.SourceConduitawaitReadable in class org.xnio.conduits.AbstractSourceConduit<org.xnio.conduits.StreamSourceConduit>IOExceptionpublic void terminateReads()
throws IOException terminateReads in interface org.xnio.conduits.SourceConduitterminateReads in class org.xnio.conduits.AbstractSourceConduit<org.xnio.conduits.StreamSourceConduit>IOExceptionpublic void resumeReads()
resumeReads in interface org.xnio.conduits.SourceConduitresumeReads in class org.xnio.conduits.AbstractSourceConduit<org.xnio.conduits.StreamSourceConduit>public void suspendReads()
suspendReads in interface org.xnio.conduits.SourceConduitsuspendReads in class org.xnio.conduits.AbstractSourceConduit<org.xnio.conduits.StreamSourceConduit>public void wakeupReads()
wakeupReads in interface org.xnio.conduits.SourceConduitwakeupReads in class org.xnio.conduits.AbstractSourceConduit<org.xnio.conduits.StreamSourceConduit>Copyright © 2020 JBoss by Red Hat. All rights reserved.