Top Fields Constructors Methods
io.vertx.core.http.impl

pack-priv abstract Class VertxHttp2Stream<C extends Http2ConnectionBase>

extends Object
Class Inheritance
Known Direct Subclasses
io.vertx.core.http.impl.Http2ClientConnection.Stream, io.vertx.core.http.impl.Http2ServerStream
Imports
io.netty.buffer.ByteBuf, .Unpooled, io.netty.channel.EventLoop, io.netty.handler.codec.http2.EmptyHttp2Headers, .Http2Headers, .Http2Stream, io.netty.util.concurrent.FutureListener, io.vertx.core.AsyncResult, .Handler, .MultiMap, io.vertx.core.buffer.Buffer, io.vertx.core.http.HttpFrame, .StreamPriority, .StreamResetException, io.vertx.core.http.impl.headers.Http2HeadersAdaptor, io.vertx.core.impl.ContextInternal, .VertxInternal, io.vertx.core.streams.impl.InboundBuffer
Author
Julien Viet

Field Summary

Modifier and TypeField and Description
private long
bytesRead

private long
bytesWritten

protected final C
conn

protected final ContextInternal
context

private static final MultiMap
EMPTY

protected boolean
isConnect

private final InboundBuffer<Object>
pending

private StreamPriority
priority

private long
reset

protected Http2Stream
stream

protected final VertxInternal
vertx

private boolean
writable

private int
writeInProgress

Constructor Summary

AccessConstructor and Description
pack-priv
VertxHttp2Stream(C conn, ContextInternal context)

Method Summary

Modifier and TypeMethod and Description
pack-priv long
bytesRead()

pack-priv long
bytesWritten()

protected final boolean
checkReset(Handler<AsyncResult<Void>> handler)

public void
doFetch(long amount)

public void
doPause()

pack-priv void
doWriteData(ByteBuf buf, boolean end, Handler<AsyncResult<Void>> handler)

private void
doWriteFrame(int type, int flags, ByteBuf payload)

pack-priv void
doWriteHeaders(Http2Headers headers, boolean end, boolean checkFlush, Handler<AsyncResult<Void>> handler)

protected void
doWriteReset(long code)

protected void
endWritten()

pack-priv void
handleClose()

pack-priv void
handleCustomFrame(HttpFrame frame)

pack-priv void
handleData(Buffer buf)
References Deprecated Buffer is deprecated or references (maybe indirectly) at least one deprecated element.

pack-priv void
handleEnd(MultiMap trailers)

pack-priv void
handleException(Throwable cause)

pack-priv void
handlePriorityChange(StreamPriority newPriority)

pack-priv void
handleReset(long errorCode)

pack-priv void
handleWritabilityChanged(boolean writable)

public int
id()

pack-priv void
init(Http2Stream stream)

public synchronized boolean
isNotWritable()

pack-priv void
onClose()

pack-priv void
onCustomFrame(HttpFrame frame)

pack-priv void
onData(Buffer data)
References Deprecated Buffer is deprecated or references (maybe indirectly) at least one deprecated element.

pack-priv void
onEnd()

pack-priv void
onEnd(MultiMap trailers)

pack-priv void
onException(Throwable cause)

pack-priv void
onHeaders(Http2Headers headers, StreamPriority streamPriority)

pack-priv void
onPriorityChange(StreamPriority newPriority)

pack-priv void
onReset(long code)

pack-priv void
onWritabilityChanged()

pack-priv synchronized void
priority(StreamPriority streamPriority)

pack-priv synchronized StreamPriority
priority()

protected void
queueForWrite(EventLoop eventLoop, Runnable action)

protected boolean
shouldQueue(EventLoop eventLoop)

pack-priv synchronized void
updatePriority(StreamPriority priority)

pack-priv final void
writeData(ByteBuf chunk, boolean end, Handler<AsyncResult<Void>> handler)

public final void
writeFrame(int type, int flags, ByteBuf payload)

pack-priv final void
writeHeaders(Http2Headers headers, boolean end, boolean checkFlush, Handler<AsyncResult<Void>> handler)

private void
writePriorityFrame(StreamPriority priority)

pack-priv final void
writeReset(long code)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

bytesReadback to summary
private long bytesRead
bytesWrittenback to summary
private long bytesWritten
connback to summary
protected final C conn
contextback to summary
protected final ContextInternal context
EMPTYback to summary
private static final MultiMap EMPTY
isConnectback to summary
protected boolean isConnect
pendingback to summary
private final InboundBuffer<Object> pending
priorityback to summary
private StreamPriority priority
resetback to summary
private long reset
streamback to summary
protected Http2Stream stream
vertxback to summary
protected final VertxInternal vertx
writableback to summary
private boolean writable
writeInProgressback to summary
private int writeInProgress

Constructor Detail

VertxHttp2Streamback to summary
pack-priv VertxHttp2Stream(C conn, ContextInternal context)

Method Detail

bytesReadback to summary
pack-priv long bytesRead()
bytesWrittenback to summary
pack-priv long bytesWritten()
checkResetback to summary
protected final boolean checkReset(Handler<AsyncResult<Void>> handler)
doFetchback to summary
public void doFetch(long amount)
doPauseback to summary
public void doPause()
doWriteDataback to summary
pack-priv void doWriteData(ByteBuf buf, boolean end, Handler<AsyncResult<Void>> handler)
doWriteFrameback to summary
private void doWriteFrame(int type, int flags, ByteBuf payload)
doWriteHeadersback to summary
pack-priv void doWriteHeaders(Http2Headers headers, boolean end, boolean checkFlush, Handler<AsyncResult<Void>> handler)
doWriteResetback to summary
protected void doWriteReset(long code)
endWrittenback to summary
protected void endWritten()
handleCloseback to summary
pack-priv void handleClose()
handleCustomFrameback to summary
pack-priv void handleCustomFrame(HttpFrame frame)
handleDataback to summary
pack-priv void handleData(Buffer buf)

References Deprecated

Buffer is deprecated or references (maybe indirectly) at least one deprecated element.

See corresponding docs for further information.

handleEndback to summary
pack-priv void handleEnd(MultiMap trailers)
handleExceptionback to summary
pack-priv void handleException(Throwable cause)
handlePriorityChangeback to summary
pack-priv void handlePriorityChange(StreamPriority newPriority)
handleResetback to summary
pack-priv void handleReset(long errorCode)
handleWritabilityChangedback to summary
pack-priv void handleWritabilityChanged(boolean writable)
idback to summary
public int id()
initback to summary
pack-priv void init(Http2Stream stream)
isNotWritableback to summary
public synchronized boolean isNotWritable()
onCloseback to summary
pack-priv void onClose()
onCustomFrameback to summary
pack-priv void onCustomFrame(HttpFrame frame)
onDataback to summary
pack-priv void onData(Buffer data)

References Deprecated

Buffer is deprecated or references (maybe indirectly) at least one deprecated element.

See corresponding docs for further information.

onEndback to summary
pack-priv void onEnd()
onEndback to summary
pack-priv void onEnd(MultiMap trailers)
onExceptionback to summary
pack-priv void onException(Throwable cause)
onHeadersback to summary
pack-priv void onHeaders(Http2Headers headers, StreamPriority streamPriority)
onPriorityChangeback to summary
pack-priv void onPriorityChange(StreamPriority newPriority)
onResetback to summary
pack-priv void onReset(long code)
onWritabilityChangedback to summary
pack-priv void onWritabilityChanged()
priorityback to summary
pack-priv synchronized void priority(StreamPriority streamPriority)
priorityback to summary
pack-priv synchronized StreamPriority priority()
queueForWriteback to summary
protected void queueForWrite(EventLoop eventLoop, Runnable action)
shouldQueueback to summary
protected boolean shouldQueue(EventLoop eventLoop)
updatePriorityback to summary
pack-priv synchronized void updatePriority(StreamPriority priority)
writeDataback to summary
pack-priv final void writeData(ByteBuf chunk, boolean end, Handler<AsyncResult<Void>> handler)
writeFrameback to summary
public final void writeFrame(int type, int flags, ByteBuf payload)
writeHeadersback to summary
pack-priv final void writeHeaders(Http2Headers headers, boolean end, boolean checkFlush, Handler<AsyncResult<Void>> handler)
writePriorityFrameback to summary
private void writePriorityFrame(StreamPriority priority)
writeResetback to summary
pack-priv final void writeReset(long code)