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>
Options.READ_TIMEOUT
Constructor | Description |
---|---|
ReadTimeoutStreamSourceConduit(org.xnio.conduits.StreamSourceConduit delegate,
org.xnio.StreamConnection connection,
OpenListener openListener) |
Modifier and Type | Method | Description |
---|---|---|
void |
awaitReadable() |
|
void |
awaitReadable(long time,
java.util.concurrent.TimeUnit timeUnit) |
|
int |
read(java.nio.ByteBuffer dst) |
|
long |
read(java.nio.ByteBuffer[] dsts,
int offset,
int length) |
|
void |
resumeReads() |
|
void |
suspendReads() |
|
void |
terminateReads() |
|
long |
transferTo(long position,
long count,
java.nio.channels.FileChannel target) |
|
long |
transferTo(long count,
java.nio.ByteBuffer throughBuffer,
org.xnio.channels.StreamSinkChannel target) |
|
void |
wakeupReads() |
getReadThread, isReadResumed, isReadShutdown, setReadReadyHandler
public ReadTimeoutStreamSourceConduit(org.xnio.conduits.StreamSourceConduit delegate, org.xnio.StreamConnection connection, OpenListener openListener)
public long transferTo(long position, long count, java.nio.channels.FileChannel target) throws java.io.IOException
transferTo
in interface org.xnio.conduits.StreamSourceConduit
transferTo
in class org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>
java.io.IOException
public long transferTo(long count, java.nio.ByteBuffer throughBuffer, org.xnio.channels.StreamSinkChannel target) throws java.io.IOException
transferTo
in interface org.xnio.conduits.StreamSourceConduit
transferTo
in class org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>
java.io.IOException
public long read(java.nio.ByteBuffer[] dsts, int offset, int length) throws java.io.IOException
read
in interface org.xnio.conduits.StreamSourceConduit
read
in class org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>
java.io.IOException
public int read(java.nio.ByteBuffer dst) throws java.io.IOException
read
in interface org.xnio.conduits.StreamSourceConduit
read
in class org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>
java.io.IOException
public void awaitReadable() throws java.io.IOException
awaitReadable
in interface org.xnio.conduits.SourceConduit
awaitReadable
in class org.xnio.conduits.AbstractSourceConduit<org.xnio.conduits.StreamSourceConduit>
java.io.IOException
public void awaitReadable(long time, java.util.concurrent.TimeUnit timeUnit) throws java.io.IOException
awaitReadable
in interface org.xnio.conduits.SourceConduit
awaitReadable
in class org.xnio.conduits.AbstractSourceConduit<org.xnio.conduits.StreamSourceConduit>
java.io.IOException
public void terminateReads() throws java.io.IOException
terminateReads
in interface org.xnio.conduits.SourceConduit
terminateReads
in class org.xnio.conduits.AbstractSourceConduit<org.xnio.conduits.StreamSourceConduit>
java.io.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 © 2018. All rights reserved.