Uses of Interface
io.netty.handler.codec.http2.Http2Stream
Packages that use Http2Stream
-
Uses of Http2Stream in io.netty.handler.codec.http2
Fields in io.netty.handler.codec.http2 declared as Http2StreamModifier and TypeFieldDescriptionprotected final Http2StreamDefaultHttp2ConnectionEncoder.FlowControlledBase.streamMethods in io.netty.handler.codec.http2 that return Http2StreamModifier and TypeMethodDescriptionHttp2Stream.close()Closes the stream.Http2Stream.closeLocalSide()Closes the local side of this stream.Http2Stream.closeRemoteSide()Closes the remote side of this stream.DefaultHttp2Connection.connectionStream()Http2Connection.connectionStream()Gets the stream object representing the connection, itself (i.e. stream zero).Http2Connection.Endpoint.createStream(int streamId, boolean halfClosed) Creates a stream initiated by this endpoint.DefaultHttp2Connection.forEachActiveStream(Http2StreamVisitor visitor) Http2Connection.forEachActiveStream(Http2StreamVisitor visitor) Provide a means of iterating over the collection of active streams.Http2Stream.headersReceived(boolean isInformational) Indicates that headers have been received.Http2Stream.headersSent(boolean isInformational) Indicates that headers have been sent to the remote endpoint on this stream.Http2Stream.open(boolean halfClosed) Opens this stream, making it available viaHttp2Connection.forEachActiveStream(Http2StreamVisitor)and transition state to:Http2Stream.State.OPENifHttp2Stream.state()isHttp2Stream.State.IDLEandhalfClosedisfalse.Http2Stream.State.HALF_CLOSED_LOCALifHttp2Stream.state()isHttp2Stream.State.IDLEandhalfClosedistrueand the stream is local.Http2Stream.pushPromiseSent()Indicates that a push promise was sent to the remote endpoint.Http2Connection.Endpoint.reservePushStream(int streamId, Http2Stream parent) Creates a push stream in the reserved state for this endpoint and notifies all listeners.Http2Stream.resetSent()Sets the flag indicating that aRST_STREAMframe has been sent from the local endpoint for this stream.DefaultHttp2Connection.stream(int streamId) Http2Connection.stream(int streamId) Gets the stream if it exists.StreamByteDistributor.StreamState.stream()Gets the stream this state is associated with.Methods in io.netty.handler.codec.http2 with parameters of type Http2StreamModifier and TypeMethodDescriptionvoidDefaultHttp2RemoteFlowController.addFlowControlled(Http2Stream stream, Http2RemoteFlowController.FlowControlled frame) voidHttp2RemoteFlowController.addFlowControlled(Http2Stream stream, Http2RemoteFlowController.FlowControlled payload) Queues a payload for transmission to the remote endpoint.voidHttp2ConnectionHandler.closeStream(Http2Stream stream, ChannelFuture future) voidHttp2LifecycleManager.closeStream(Http2Stream stream, ChannelFuture future) Closes and deactivates the givenstream.voidHttp2ConnectionHandler.closeStreamLocal(Http2Stream stream, ChannelFuture future) Closes the local side of the given stream.voidHttp2LifecycleManager.closeStreamLocal(Http2Stream stream, ChannelFuture future) Closes the local side of thestream.voidHttp2ConnectionHandler.closeStreamRemote(Http2Stream stream, ChannelFuture future) Closes the remote side of the given stream.voidHttp2LifecycleManager.closeStreamRemote(Http2Stream stream, ChannelFuture future) Closes the remote side of thestream.booleanDefaultHttp2LocalFlowController.consumeBytes(Http2Stream stream, int numBytes) booleanHttp2LocalFlowController.consumeBytes(Http2Stream stream, int numBytes) Indicates that the application has consumed a number of bytes for the given stream and is therefore ready to receive more data from the remote endpoint.booleanHttp2Connection.Endpoint.created(Http2Stream stream) Indicates whether or not this endpoint created the given stream.protected voidInboundHttp2ToHttpAdapter.fireChannelRead(ChannelHandlerContext ctx, FullHttpMessage msg, boolean release, Http2Stream stream) Set final headers and fire a channel read eventprotected final FullHttpMessageInboundHttp2ToHttpAdapter.getMessage(Http2Stream stream) Get theFullHttpMessageassociated withstream.protected voidHttp2ConnectionHandler.handleServerHeaderDecodeSizeError(ChannelHandlerContext ctx, Http2Stream stream) Notifies client that this server has received headers that are larger than what it is willing to accept.booleanDefaultHttp2RemoteFlowController.hasFlowControlled(Http2Stream stream) booleanHttp2RemoteFlowController.hasFlowControlled(Http2Stream stream) Determine ifstreamhas anyHttp2RemoteFlowController.FlowControlledframes currently queued.voidDefaultHttp2LocalFlowController.incrementWindowSize(Http2Stream stream, int delta) voidDefaultHttp2RemoteFlowController.incrementWindowSize(Http2Stream stream, int delta) voidHttp2FlowController.incrementWindowSize(Http2Stream stream, int delta) Increments the size of the stream's flow control window by the given delta.intDefaultHttp2LocalFlowController.initialWindowSize(Http2Stream stream) intHttp2LocalFlowController.initialWindowSize(Http2Stream stream) Get the initial flow control window size for the given stream.booleanDefaultHttp2RemoteFlowController.isWritable(Http2Stream stream) booleanHttp2RemoteFlowController.isWritable(Http2Stream stream) Determine if thestreamhas bytes remaining for use in the flow control window.protected FullHttpMessageInboundHttp2ToHttpAdapter.newMessage(Http2Stream stream, Http2Headers headers, boolean validateHttpHeaders, ByteBufAllocator alloc) Create a newFullHttpMessagebased upon the current connection parametersprotected voidInboundHttp2ToHttpAdapter.onRstStreamRead(Http2Stream stream, FullHttpMessage msg) Called if aRST_STREAMis received but we have some data for that stream.voidHttp2Connection.Listener.onStreamActive(Http2Stream stream) Notifies the listener that the given stream was made active (i.e.voidHttp2ConnectionAdapter.onStreamActive(Http2Stream stream) voidHttp2EventAdapter.onStreamActive(Http2Stream stream) voidHttp2Connection.Listener.onStreamAdded(Http2Stream stream) Notifies the listener that the given stream was added to the connection.voidHttp2ConnectionAdapter.onStreamAdded(Http2Stream stream) voidHttp2EventAdapter.onStreamAdded(Http2Stream stream) voidHttp2Connection.Listener.onStreamClosed(Http2Stream stream) Notifies the listener that the given stream is nowCLOSEDin both directions and will no longer be accessible viaHttp2Connection.forEachActiveStream(Http2StreamVisitor).voidHttp2ConnectionAdapter.onStreamClosed(Http2Stream stream) voidHttp2EventAdapter.onStreamClosed(Http2Stream stream) voidHttp2Connection.Listener.onStreamHalfClosed(Http2Stream stream) Notifies the listener that the given stream has transitioned fromOPENtoHALF CLOSED.voidHttp2ConnectionAdapter.onStreamHalfClosed(Http2Stream stream) voidHttp2EventAdapter.onStreamHalfClosed(Http2Stream stream) voidHttp2Connection.Listener.onStreamRemoved(Http2Stream stream) Notifies the listener that the given stream has now been removed from the connection and will no longer be returned viaHttp2Connection.stream(int).voidHttp2ConnectionAdapter.onStreamRemoved(Http2Stream stream) voidHttp2EventAdapter.onStreamRemoved(Http2Stream stream) voidInboundHttp2ToHttpAdapter.onStreamRemoved(Http2Stream stream) protected FullHttpMessageInboundHttp2ToHttpAdapter.processHeadersBegin(ChannelHandlerContext ctx, Http2Stream stream, Http2Headers headers, boolean endOfStream, boolean allowAppend, boolean appendToTrailer) Provides translation between HTTP/2 and HTTP header objects while ensuring the stream is in a valid state for additional headers.protected final voidInboundHttp2ToHttpAdapter.putMessage(Http2Stream stream, FullHttpMessage message) Makemessagebe the state associated withstream.voidDefaultHttp2LocalFlowController.receiveFlowControlledFrame(Http2Stream stream, ByteBuf data, int padding, boolean endOfStream) voidHttp2LocalFlowController.receiveFlowControlledFrame(Http2Stream stream, ByteBuf data, int padding, boolean endOfStream) Receives an inboundDATAframe from the remote endpoint and applies flow control policies to it for both thestreamas well as the connection.protected final voidInboundHttp2ToHttpAdapter.removeMessage(Http2Stream stream, boolean release) The stream is out of scope for the HTTP message flow and will no longer be trackedHttp2Connection.Endpoint.reservePushStream(int streamId, Http2Stream parent) Creates a push stream in the reserved state for this endpoint and notifies all listeners.intDefaultHttp2LocalFlowController.unconsumedBytes(Http2Stream stream) intHttp2LocalFlowController.unconsumedBytes(Http2Stream stream) The number of bytes for the given stream that have been received but not yet consumed by the application.booleanHttp2StreamVisitor.visit(Http2Stream stream) intDefaultHttp2LocalFlowController.windowSize(Http2Stream stream) intDefaultHttp2RemoteFlowController.windowSize(Http2Stream stream) intHttp2FlowController.windowSize(Http2Stream stream) Get the portion of the flow control window for the given stream that is currently available for sending/receiving frames which are subject to flow control.floatDefaultHttp2LocalFlowController.windowUpdateRatio(Http2Stream stream) The window update ratio is used to determine when a window update must be sent.voidDefaultHttp2LocalFlowController.windowUpdateRatio(Http2Stream stream, float ratio) The window update ratio is used to determine when a window update must be sent.voidHttp2RemoteFlowController.Listener.writabilityChanged(Http2Stream stream) Notification thatHttp2RemoteFlowController.isWritable(Http2Stream)has changed forstream.voidStreamByteDistributor.Writer.write(Http2Stream stream, int numBytes) Writes the allocated bytes for this stream.