public class InflatingStreamSourceConduit
extends org.xnio.conduits.AbstractStreamSourceConduit<org.xnio.conduits.StreamSourceConduit>
Modifier and Type | Field and Description |
---|---|
static ConduitWrapper<org.xnio.conduits.StreamSourceConduit> | WRAPPER |
Constructor and Description |
---|
InflatingStreamSourceConduit(HttpServerExchange exchange, org.xnio.conduits.StreamSourceConduit next) |
InflatingStreamSourceConduit(HttpServerExchange exchange, org.xnio.conduits.StreamSourceConduit next, ObjectPool<Inflater> inflaterPool) |
Modifier and Type | Method and Description |
---|---|
protected void | dataDeflated(byte[] data, int off, int len) |
static ObjectPool<Inflater> | newInstanceInflaterPool() |
int | read(ByteBuffer dst) |
long | read(ByteBuffer[] dsts, int offset, int length) |
protected void | readFooter(ByteBuffer buf) |
protected boolean | readHeader(ByteBuffer byteBuffer) |
static ObjectPool<Inflater> | simpleInflaterPool(int poolSize) |
void | terminateReads() |
long | transferTo(long count, ByteBuffer throughBuffer, org.xnio.channels.StreamSinkChannel target) |
long | transferTo(long position, long count, FileChannel target) |
awaitReadable, awaitReadable, getReadThread, isReadResumed, isReadShutdown, resumeReads, setReadReadyHandler, suspendReads, wakeupReads
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public static final ConduitWrapper<org.xnio.conduits.StreamSourceConduit> WRAPPER
public InflatingStreamSourceConduit(HttpServerExchange exchange, org.xnio.conduits.StreamSourceConduit next)
public InflatingStreamSourceConduit(HttpServerExchange exchange, org.xnio.conduits.StreamSourceConduit next, ObjectPool<Inflater> inflaterPool)
public static ObjectPool<Inflater> newInstanceInflaterPool()
public static ObjectPool<Inflater> simpleInflaterPool(int poolSize)
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
protected void readFooter(ByteBuffer buf) throws IOException
IOException
protected boolean readHeader(ByteBuffer byteBuffer) throws IOException
IOException
protected void dataDeflated(byte[] data, int off, int len)
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 void terminateReads() throws IOException
terminateReads
in interface org.xnio.conduits.SourceConduit
terminateReads
in class org.xnio.conduits.AbstractSourceConduit<org.xnio.conduits.StreamSourceConduit>
IOException
Copyright © 2020 JBoss by Red Hat. All rights reserved.