Package dev.relism.flash.http2.message

Class Http2RequestBody

java.lang.Object

java.io.InputStream

dev.relism.flash.http2.message.Http2RequestBody

All Implemented Interfaces:

BodyCompletion, Closeable, AutoCloseable

public final class Http2RequestBody
extends InputStream
implements BodyCompletion

Reusable request-body source fed by the connection demultiplexer.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	Http2RequestBody.ConsumptionListener

Constructor Summary

Constructors

Constructor	Description
Http2RequestBody(DataBufferPool pool)

Method Summary

Modifier and Type	Method	Description
void	begin(long declaredLength, boolean inlineMode, Http2RequestBody.ConsumptionListener listener)
int	cancel()
long	declaredLength()
void	finish(int streamId)
boolean	fullyRead()
void	offer(int streamId, byte[] source, int offset, int length, int flowControlledBytes)
int	read()
int	read(byte[] target, int offset, int length)

Methods inherited from class java.io.InputStream

available, close, mark, markSupported, nullInputStream, read, readAllBytes, readNBytes, readNBytes, reset, skip, skipNBytes, transferTo

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Http2RequestBody

public Http2RequestBody(DataBufferPool pool)

Method Details

begin

public void begin(long declaredLength,
 boolean inlineMode,
 Http2RequestBody.ConsumptionListener listener)

offer

public void offer(int streamId,
 byte[] source,
 int offset,
 int length,
 int flowControlledBytes)

finish

public void finish(int streamId)

cancel

public int cancel()

declaredLength

public long declaredLength()

read

public int read()
         throws IOException

Specified by:

read in class InputStream

Throws:

IOException

read

public int read(byte[] target,
 int offset,
 int length)
         throws IOException

Overrides:

read in class InputStream

Throws:

IOException

fullyRead

public boolean fullyRead()

Specified by:

fullyRead in interface BodyCompletion