public static int initiateStream ( ChannelHandlerContext ctx , Http2Connection connection , Http2ClientChannel http2ClientChannel , OutboundMsgHolder outboundMsgHolder ) throws Http2Exception { int streamId = getNextStreamId ( connection ) ; createStream ( connection , streamId ) ; http2ClientChannel . putInFlightMessage ( streamId , outboundMsgHolder ) ; http2ClientChannel . getDataEventListeners ( ) . forEach ( dataEventListener -> dataEventListener . onStreamInit ( ctx , streamId ) ) ; return streamId ; }
Initiates a HTTP2 stream .