1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17 package io.netty.handler.codec.http3;
18
19 import io.netty.channel.ChannelHandler;
20 import io.netty.channel.ChannelHandlerContext;
21 import io.netty.handler.codec.http3.Http3FrameCodec.Http3FrameCodecFactory;
22 import io.netty.handler.codec.http3.Http3Settings.NonStandardHttp3SettingsValidator;
23 import org.jetbrains.annotations.Nullable;
24
25 import java.util.function.LongFunction;
26 import java.util.function.Supplier;
27
28 final class Http3UnidirectionalStreamInboundServerHandler extends Http3UnidirectionalStreamInboundHandler {
29
30 Http3UnidirectionalStreamInboundServerHandler(Http3FrameCodecFactory codecFactory,
31 NonStandardHttp3SettingsValidator nonStandardSettingsValidator,
32 Http3ControlStreamInboundHandler localControlStreamHandler,
33 Http3ControlStreamOutboundHandler remoteControlStreamHandler,
34 @Nullable LongFunction<ChannelHandler> unknownStreamHandlerFactory,
35 Supplier<ChannelHandler> qpackEncoderHandlerFactory,
36 Supplier<ChannelHandler> qpackDecoderHandlerFactory) {
37 super(codecFactory, nonStandardSettingsValidator, localControlStreamHandler, remoteControlStreamHandler,
38 unknownStreamHandlerFactory, qpackEncoderHandlerFactory, qpackDecoderHandlerFactory);
39 }
40
41 @Override
42 void initPushStream(ChannelHandlerContext ctx, long id) {
43 Http3CodecUtils.connectionError(ctx, Http3ErrorCode.H3_STREAM_CREATION_ERROR,
44 "Server received push stream.", false);
45 }
46 }