abstract class io.micronaut.http.netty.stream.HttpStreamsHandler<In extends io.netty.handler.codec.http.HttpMessage, Out extends io.netty.handler.codec.http.HttpMessage> extends io.netty.channel.ChannelDuplexHandler
minor version: 0
major version: 59
flags: flags: (0x0420) ACC_SUPER, ACC_ABSTRACT
this_class: io.micronaut.http.netty.stream.HttpStreamsHandler
super_class: io.netty.channel.ChannelDuplexHandler
{
public static final java.lang.String HANDLER_BODY_PUBLISHER;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "http-streams-codec-body-publisher"
private static final org.slf4j.Logger LOG;
descriptor: Lorg/slf4j/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private final java.util.Queue<io.micronaut.http.netty.stream.HttpStreamsHandler<In, Out>.Outgoing> outgoing;
descriptor: Ljava/util/Queue;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Queue<Lio/micronaut/http/netty/stream/HttpStreamsHandler<TIn;TOut;>.Outgoing;>;
private final java.lang.Class<In> inClass;
descriptor: Ljava/lang/Class;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/lang/Class<TIn;>;
private final java.lang.Class<Out> outClass;
descriptor: Ljava/lang/Class;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/lang/Class<TOut;>;
private In currentlyStreamedMessage;
descriptor: Lio/netty/handler/codec/http/HttpMessage;
flags: (0x0002) ACC_PRIVATE
Signature: TIn;
private boolean ignoreBodyRead;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private boolean sendLastHttpContent;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Lio/micronaut/http/netty/stream/HttpStreamsHandler;
invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
putstatic io.micronaut.http.netty.stream.HttpStreamsHandler.LOG:Lorg/slf4j/Logger;
return
LocalVariableTable:
Start End Slot Name Signature
void <init>(java.lang.Class<In>, java.lang.Class<Out>);
descriptor: (Ljava/lang/Class;Ljava/lang/Class;)V
flags: (0x0000)
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokespecial io.netty.channel.ChannelDuplexHandler.<init>:()V
1: aload 0
new java.util.LinkedList
dup
invokespecial java.util.LinkedList.<init>:()V
putfield io.micronaut.http.netty.stream.HttpStreamsHandler.outgoing:Ljava/util/Queue;
2: aload 0
aload 1
putfield io.micronaut.http.netty.stream.HttpStreamsHandler.inClass:Ljava/lang/Class;
3: aload 0
aload 2
putfield io.micronaut.http.netty.stream.HttpStreamsHandler.outClass:Ljava/lang/Class;
4: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/micronaut/http/netty/stream/HttpStreamsHandler<TIn;TOut;>;
0 5 1 inClass Ljava/lang/Class<TIn;>;
0 5 2 outClass Ljava/lang/Class<TOut;>;
Signature: (Ljava/lang/Class<TIn;>;Ljava/lang/Class<TOut;>;)V
MethodParameters:
Name Flags
inClass
outClass
protected abstract boolean hasBody();
descriptor: (Lio/netty/handler/codec/http/HttpMessage;)Z
flags: (0x0404) ACC_PROTECTED, ACC_ABSTRACT
Signature: (TIn;)Z
MethodParameters:
Name Flags
in
protected abstract In createEmptyMessage();
descriptor: (Lio/netty/handler/codec/http/HttpMessage;)Lio/netty/handler/codec/http/HttpMessage;
flags: (0x0404) ACC_PROTECTED, ACC_ABSTRACT
Signature: (TIn;)TIn;
MethodParameters:
Name Flags
in
protected abstract In createStreamedMessage(In, org.reactivestreams.Publisher<? extends io.netty.handler.codec.http.HttpContent>);
descriptor: (Lio/netty/handler/codec/http/HttpMessage;Lorg/reactivestreams/Publisher;)Lio/netty/handler/codec/http/HttpMessage;
flags: (0x0404) ACC_PROTECTED, ACC_ABSTRACT
Signature: (TIn;Lorg/reactivestreams/Publisher<+Lio/netty/handler/codec/http/HttpContent;>;)TIn;
MethodParameters:
Name Flags
in
stream
protected void receivedInMessage(io.netty.channel.ChannelHandlerContext);
descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=0, locals=2, args_size=2
start local 0 start local 1 0: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/micronaut/http/netty/stream/HttpStreamsHandler<TIn;TOut;>;
0 1 1 ctx Lio/netty/channel/ChannelHandlerContext;
MethodParameters:
Name Flags
ctx
protected void consumedInMessage(io.netty.channel.ChannelHandlerContext);
descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=0, locals=2, args_size=2
start local 0 start local 1 0: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/micronaut/http/netty/stream/HttpStreamsHandler<TIn;TOut;>;
0 1 1 ctx Lio/netty/channel/ChannelHandlerContext;
MethodParameters:
Name Flags
ctx
protected void receivedOutMessage(io.netty.channel.ChannelHandlerContext);
descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=0, locals=2, args_size=2
start local 0 start local 1 0: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/micronaut/http/netty/stream/HttpStreamsHandler<TIn;TOut;>;
0 1 1 ctx Lio/netty/channel/ChannelHandlerContext;
MethodParameters:
Name Flags
ctx
protected void sentOutMessage(io.netty.channel.ChannelHandlerContext);
descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=0, locals=2, args_size=2
start local 0 start local 1 0: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/micronaut/http/netty/stream/HttpStreamsHandler<TIn;TOut;>;
0 1 1 ctx Lio/netty/channel/ChannelHandlerContext;
MethodParameters:
Name Flags
ctx
protected void subscribeSubscriberToStream(io.micronaut.http.netty.stream.StreamedHttpMessage, org.reactivestreams.Subscriber<io.netty.handler.codec.http.HttpContent>);
descriptor: (Lio/micronaut/http/netty/stream/StreamedHttpMessage;Lorg/reactivestreams/Subscriber;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 1
aload 2
invokeinterface io.micronaut.http.netty.stream.StreamedHttpMessage.subscribe:(Lorg/reactivestreams/Subscriber;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/micronaut/http/netty/stream/HttpStreamsHandler<TIn;TOut;>;
0 2 1 msg Lio/micronaut/http/netty/stream/StreamedHttpMessage;
0 2 2 subscriber Lorg/reactivestreams/Subscriber<Lio/netty/handler/codec/http/HttpContent;>;
Signature: (Lio/micronaut/http/netty/stream/StreamedHttpMessage;Lorg/reactivestreams/Subscriber<Lio/netty/handler/codec/http/HttpContent;>;)V
MethodParameters:
Name Flags
msg
subscriber
protected void bodyRequested(io.netty.channel.ChannelHandlerContext);
descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=0, locals=2, args_size=2
start local 0 start local 1 0: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/micronaut/http/netty/stream/HttpStreamsHandler<TIn;TOut;>;
0 1 1 ctx Lio/netty/channel/ChannelHandlerContext;
MethodParameters:
Name Flags
ctx
protected abstract boolean isClient();
descriptor: ()Z
flags: (0x0404) ACC_PROTECTED, ACC_ABSTRACT
public void channelRead(io.netty.channel.ChannelHandlerContext, java.lang.Object);
descriptor: (Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=8, locals=6, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 2
invokevirtual io.micronaut.http.netty.stream.HttpStreamsHandler.isValidInMessage:(Ljava/lang/Object;)Z
ifeq 21
1: aload 0
aload 1
invokevirtual io.micronaut.http.netty.stream.HttpStreamsHandler.receivedInMessage:(Lio/netty/channel/ChannelHandlerContext;)V
2: aload 0
getfield io.micronaut.http.netty.stream.HttpStreamsHandler.inClass:Ljava/lang/Class;
aload 2
invokevirtual java.lang.Class.cast:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.netty.handler.codec.http.HttpMessage
astore 3
start local 3 3: aload 3
instanceof io.netty.handler.codec.http.FullHttpMessage
ifeq 7
4: aload 1
aload 3
invokeinterface io.netty.channel.ChannelHandlerContext.fireChannelRead:(Ljava/lang/Object;)Lio/netty/channel/ChannelHandlerContext;
pop
5: aload 0
aload 1
invokevirtual io.micronaut.http.netty.stream.HttpStreamsHandler.consumedInMessage:(Lio/netty/channel/ChannelHandlerContext;)V
6: goto 23
StackMap locals: io.netty.handler.codec.http.HttpMessage
StackMap stack:
7: aload 0
aload 3
invokevirtual io.micronaut.http.netty.stream.HttpStreamsHandler.hasBody:(Lio/netty/handler/codec/http/HttpMessage;)Z
ifne 12
8: aload 1
aload 0
aload 3
invokevirtual io.micronaut.http.netty.stream.HttpStreamsHandler.createEmptyMessage:(Lio/netty/handler/codec/http/HttpMessage;)Lio/netty/handler/codec/http/HttpMessage;
invokeinterface io.netty.channel.ChannelHandlerContext.fireChannelRead:(Ljava/lang/Object;)Lio/netty/channel/ChannelHandlerContext;
pop
9: aload 0
aload 1
invokevirtual io.micronaut.http.netty.stream.HttpStreamsHandler.consumedInMessage:(Lio/netty/channel/ChannelHandlerContext;)V
10: aload 0
iconst_1
putfield io.micronaut.http.netty.stream.HttpStreamsHandler.ignoreBodyRead:Z
11: goto 23
12: StackMap locals:
StackMap stack:
aload 0
aload 3
putfield io.micronaut.http.netty.stream.HttpStreamsHandler.currentlyStreamedMessage:Lio/netty/handler/codec/http/HttpMessage;
13: aload 0
aload 2
invokevirtual io.micronaut.http.netty.stream.HttpStreamsHandler.getStreamId:(Ljava/lang/Object;)I
istore 4
start local 4 14: iload 4
iconst_m1
if_icmple 17
15: new io.micronaut.http.netty.stream.HttpStreamsHandler$1
dup
aload 0
aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.executor:()Lio/netty/util/concurrent/EventExecutor;
ldc Lio/micronaut/http/netty/stream/Http2Content;
iload 4
aload 1
aload 3
invokespecial io.micronaut.http.netty.stream.HttpStreamsHandler$1.<init>:(Lio/micronaut/http/netty/stream/HttpStreamsHandler;Lio/netty/util/concurrent/EventExecutor;Ljava/lang/Class;ILio/netty/channel/ChannelHandlerContext;Lio/netty/handler/codec/http/HttpMessage;)V
astore 5
start local 5 16: goto 18
end local 5 17: StackMap locals: int
StackMap stack:
new io.micronaut.http.netty.stream.HttpStreamsHandler$2
dup
aload 0
aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.executor:()Lio/netty/util/concurrent/EventExecutor;
ldc Lio/netty/handler/codec/http/HttpContent;
aload 1
aload 3
invokespecial io.micronaut.http.netty.stream.HttpStreamsHandler$2.<init>:(Lio/micronaut/http/netty/stream/HttpStreamsHandler;Lio/netty/util/concurrent/EventExecutor;Ljava/lang/Class;Lio/netty/channel/ChannelHandlerContext;Lio/netty/handler/codec/http/HttpMessage;)V
astore 5
start local 5 18: StackMap locals: io.micronaut.http.netty.reactive.HandlerPublisher
StackMap stack:
aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.channel:()Lio/netty/channel/Channel;
invokeinterface io.netty.channel.Channel.pipeline:()Lio/netty/channel/ChannelPipeline;
aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.name:()Ljava/lang/String;
ldc "http-streams-codec-body-publisher"
aload 5
invokeinterface io.netty.channel.ChannelPipeline.addAfter:(Ljava/lang/String;Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
pop
19: aload 1
aload 0
aload 3
aload 5
invokevirtual io.micronaut.http.netty.stream.HttpStreamsHandler.createStreamedMessage:(Lio/netty/handler/codec/http/HttpMessage;Lorg/reactivestreams/Publisher;)Lio/netty/handler/codec/http/HttpMessage;
invokeinterface io.netty.channel.ChannelHandlerContext.fireChannelRead:(Ljava/lang/Object;)Lio/netty/channel/ChannelHandlerContext;
pop
end local 5 end local 4 end local 3 20: goto 23
StackMap locals:
StackMap stack:
21: aload 2
instanceof io.netty.handler.codec.http.HttpContent
ifeq 23
22: aload 0
aload 1
aload 2
checkcast io.netty.handler.codec.http.HttpContent
invokevirtual io.micronaut.http.netty.stream.HttpStreamsHandler.handleReadHttpContent:(Lio/netty/channel/ChannelHandlerContext;Lio/netty/handler/codec/http/HttpContent;)V
23: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 24 0 this Lio/micronaut/http/netty/stream/HttpStreamsHandler<TIn;TOut;>;
0 24 1 ctx Lio/netty/channel/ChannelHandlerContext;
0 24 2 msg Ljava/lang/Object;
3 20 3 inMsg TIn;
14 20 4 streamId I
16 17 5 publisher Lio/micronaut/http/netty/reactive/HandlerPublisher<+Lio/netty/handler/codec/http/HttpContent;>;
18 20 5 publisher Lio/micronaut/http/netty/reactive/HandlerPublisher<+Lio/netty/handler/codec/http/HttpContent;>;
Exceptions:
throws java.lang.Exception
MethodParameters:
Name Flags
ctx final
msg
protected int getStreamId(java.lang.Object);
descriptor: (Ljava/lang/Object;)I
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 1
instanceof io.netty.handler.codec.http.HttpMessage
ifeq 2
1: aload 1
checkcast io.netty.handler.codec.http.HttpMessage
invokeinterface io.netty.handler.codec.http.HttpMessage.headers:()Lio/netty/handler/codec/http/HttpHeaders;
getstatic io.micronaut.http.netty.AbstractNettyHttpRequest.STREAM_ID:Lio/netty/util/AsciiString;
iconst_m1
invokevirtual io.netty.handler.codec.http.HttpHeaders.getInt:(Ljava/lang/CharSequence;I)I
ireturn
2: StackMap locals:
StackMap stack:
iconst_m1
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/micronaut/http/netty/stream/HttpStreamsHandler<TIn;TOut;>;
0 3 1 msg Ljava/lang/Object;
MethodParameters:
Name Flags
msg
private void handleCancelled(io.netty.channel.ChannelHandlerContext, );
descriptor: (Lio/netty/channel/ChannelHandlerContext;Lio/netty/handler/codec/http/HttpMessage;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.micronaut.http.netty.stream.HttpStreamsHandler.currentlyStreamedMessage:Lio/netty/handler/codec/http/HttpMessage;
aload 2
if_acmpne 8
1: aload 0
iconst_1
putfield io.micronaut.http.netty.stream.HttpStreamsHandler.ignoreBodyRead:Z
2: getstatic io.micronaut.http.netty.stream.HttpStreamsHandler.LOG:Lorg/slf4j/Logger;
invokeinterface org.slf4j.Logger.isTraceEnabled:()Z
ifeq 4
3: getstatic io.micronaut.http.netty.stream.HttpStreamsHandler.LOG:Lorg/slf4j/Logger;
ldc "Calling ctx.read() for cancelled subscription"
invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;)V
4: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.micronaut.http.netty.stream.HttpStreamsHandler.isClient:()Z
ifeq 7
5: aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.read:()Lio/netty/channel/ChannelHandlerContext;
pop
6: goto 8
7: StackMap locals:
StackMap stack:
aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.fireChannelWritabilityChanged:()Lio/netty/channel/ChannelHandlerContext;
pop
8: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/micronaut/http/netty/stream/HttpStreamsHandler<TIn;TOut;>;
0 9 1 ctx Lio/netty/channel/ChannelHandlerContext;
0 9 2 msg TIn;
Signature: (Lio/netty/channel/ChannelHandlerContext;TIn;)V
MethodParameters:
Name Flags
ctx
msg
private void handleReadHttpContent(io.netty.channel.ChannelHandlerContext, io.netty.handler.codec.http.HttpContent);
descriptor: (Lio/netty/channel/ChannelHandlerContext;Lio/netty/handler/codec/http/HttpContent;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.micronaut.http.netty.stream.HttpStreamsHandler.ignoreBodyRead:Z
ifne 11
1: aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
ldc "http-streams-codec-body-publisher"
invokeinterface io.netty.channel.ChannelPipeline.get:(Ljava/lang/String;)Lio/netty/channel/ChannelHandler;
astore 3
start local 3 2: aload 3
ifnull 9
3: aload 1
aload 2
invokeinterface io.netty.channel.ChannelHandlerContext.fireChannelRead:(Ljava/lang/Object;)Lio/netty/channel/ChannelHandlerContext;
pop
4: aload 2
instanceof io.netty.handler.codec.http.LastHttpContent
ifeq 17
5: aload 0
aload 1
ldc "http-streams-codec-body-publisher"
invokevirtual io.micronaut.http.netty.stream.HttpStreamsHandler.removeHandlerIfActive:(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/String;)V
6: aload 0
aconst_null
putfield io.micronaut.http.netty.stream.HttpStreamsHandler.currentlyStreamedMessage:Lio/netty/handler/codec/http/HttpMessage;
7: aload 0
aload 1
invokevirtual io.micronaut.http.netty.stream.HttpStreamsHandler.consumedInMessage:(Lio/netty/channel/ChannelHandlerContext;)V
8: goto 17
9: StackMap locals: io.netty.channel.ChannelHandler
StackMap stack:
aload 2
aload 2
invokeinterface io.netty.handler.codec.http.HttpContent.refCnt:()I
invokestatic io.netty.util.ReferenceCountUtil.release:(Ljava/lang/Object;I)Z
pop
end local 3 10: goto 17
11: StackMap locals:
StackMap stack:
aload 2
aload 2
invokeinterface io.netty.handler.codec.http.HttpContent.refCnt:()I
invokestatic io.netty.util.ReferenceCountUtil.release:(Ljava/lang/Object;I)Z
pop
12: aload 2
instanceof io.netty.handler.codec.http.LastHttpContent
ifeq 17
13: aload 0
iconst_0
putfield io.micronaut.http.netty.stream.HttpStreamsHandler.ignoreBodyRead:Z
14: aload 0
getfield io.micronaut.http.netty.stream.HttpStreamsHandler.currentlyStreamedMessage:Lio/netty/handler/codec/http/HttpMessage;
ifnull 16
15: aload 0
aload 1
ldc "http-streams-codec-body-publisher"
invokevirtual io.micronaut.http.netty.stream.HttpStreamsHandler.removeHandlerIfActive:(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/String;)V
16: StackMap locals:
StackMap stack:
aload 0
aconst_null
putfield io.micronaut.http.netty.stream.HttpStreamsHandler.currentlyStreamedMessage:Lio/netty/handler/codec/http/HttpMessage;
17: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 18 0 this Lio/micronaut/http/netty/stream/HttpStreamsHandler<TIn;TOut;>;
0 18 1 ctx Lio/netty/channel/ChannelHandlerContext;
0 18 2 content Lio/netty/handler/codec/http/HttpContent;
2 10 3 bodyPublisher Lio/netty/channel/ChannelHandler;
MethodParameters:
Name Flags
ctx
content
public void channelReadComplete(io.netty.channel.ChannelHandlerContext);
descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.micronaut.http.netty.stream.HttpStreamsHandler.ignoreBodyRead:Z
ifeq 4
1: aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.read:()Lio/netty/channel/ChannelHandlerContext;
pop
2: aload 0
iconst_0
putfield io.micronaut.http.netty.stream.HttpStreamsHandler.ignoreBodyRead:Z
3: goto 5
4: StackMap locals:
StackMap stack:
aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.fireChannelReadComplete:()Lio/netty/channel/ChannelHandlerContext;
pop
5: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/micronaut/http/netty/stream/HttpStreamsHandler<TIn;TOut;>;
0 6 1 ctx Lio/netty/channel/ChannelHandlerContext;
Exceptions:
throws java.lang.Exception
MethodParameters:
Name Flags
ctx
public void write(io.netty.channel.ChannelHandlerContext, java.lang.Object, io.netty.channel.ChannelPromise);
descriptor: (Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 2
invokevirtual io.micronaut.http.netty.stream.HttpStreamsHandler.isValidOutMessage:(Ljava/lang/Object;)Z
ifeq 9
1: new io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing
dup
aload 0
aload 0
getfield io.micronaut.http.netty.stream.HttpStreamsHandler.outClass:Ljava/lang/Class;
aload 2
invokevirtual java.lang.Class.cast:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.netty.handler.codec.http.HttpMessage
aload 3
invokespecial io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing.<init>:(Lio/micronaut/http/netty/stream/HttpStreamsHandler;Lio/netty/handler/codec/http/HttpMessage;Lio/netty/channel/ChannelPromise;)V
astore 4
start local 4 2: aload 0
aload 1
invokevirtual io.micronaut.http.netty.stream.HttpStreamsHandler.receivedOutMessage:(Lio/netty/channel/ChannelHandlerContext;)V
3: aload 0
getfield io.micronaut.http.netty.stream.HttpStreamsHandler.outgoing:Ljava/util/Queue;
invokeinterface java.util.Queue.isEmpty:()Z
ifeq 7
4: aload 0
getfield io.micronaut.http.netty.stream.HttpStreamsHandler.outgoing:Ljava/util/Queue;
aload 4
invokeinterface java.util.Queue.add:(Ljava/lang/Object;)Z
pop
5: aload 0
aload 1
invokevirtual io.micronaut.http.netty.stream.HttpStreamsHandler.flushNext:(Lio/netty/channel/ChannelHandlerContext;)V
6: goto 14
7: StackMap locals: io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing
StackMap stack:
aload 0
getfield io.micronaut.http.netty.stream.HttpStreamsHandler.outgoing:Ljava/util/Queue;
aload 4
invokeinterface java.util.Queue.add:(Ljava/lang/Object;)Z
pop
end local 4 8: goto 14
StackMap locals:
StackMap stack:
9: aload 2
instanceof io.netty.handler.codec.http.LastHttpContent
ifeq 13
10: aload 0
iconst_0
putfield io.micronaut.http.netty.stream.HttpStreamsHandler.sendLastHttpContent:Z
11: aload 1
aload 2
aload 3
invokeinterface io.netty.channel.ChannelHandlerContext.write:(Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
pop
12: goto 14
13: StackMap locals:
StackMap stack:
aload 1
aload 2
aload 3
invokeinterface io.netty.channel.ChannelHandlerContext.write:(Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
pop
14: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lio/micronaut/http/netty/stream/HttpStreamsHandler<TIn;TOut;>;
0 15 1 ctx Lio/netty/channel/ChannelHandlerContext;
0 15 2 msg Ljava/lang/Object;
0 15 3 promise Lio/netty/channel/ChannelPromise;
2 8 4 out Lio/micronaut/http/netty/stream/HttpStreamsHandler<TIn;TOut;>.Outgoing;
Exceptions:
throws java.lang.Exception
MethodParameters:
Name Flags
ctx final
msg
promise final
protected void unbufferedWrite(io.netty.channel.ChannelHandlerContext, io.micronaut.http.netty.stream.HttpStreamsHandler<In, Out>.Outgoing);
descriptor: (Lio/netty/channel/ChannelHandlerContext;Lio/micronaut/http/netty/stream/HttpStreamsHandler$Outgoing;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=5, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 2
getfield io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing.message:Lio/netty/handler/codec/http/HttpMessage;
instanceof io.netty.handler.codec.http.FullHttpMessage
ifeq 4
1: aload 1
aload 2
getfield io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing.message:Lio/netty/handler/codec/http/HttpMessage;
aload 2
getfield io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing.promise:Lio/netty/channel/ChannelPromise;
invokeinterface io.netty.channel.ChannelHandlerContext.writeAndFlush:(Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
pop
2: aload 2
getfield io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing.promise:Lio/netty/channel/ChannelPromise;
aload 0
aload 1
invokedynamic operationComplete(Lio/micronaut/http/netty/stream/HttpStreamsHandler;Lio/netty/channel/ChannelHandlerContext;)Lio/netty/util/concurrent/GenericFutureListener;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Lio/netty/util/concurrent/Future;)V
io/micronaut/http/netty/stream/HttpStreamsHandler.lambda$0(Lio/netty/channel/ChannelHandlerContext;Lio/netty/util/concurrent/Future;)V (7)
(Lio/netty/util/concurrent/Future;)V
invokeinterface io.netty.channel.ChannelPromise.addListener:(Lio/netty/util/concurrent/GenericFutureListener;)Lio/netty/channel/ChannelPromise;
pop
3: goto 11
StackMap locals:
StackMap stack:
4: aload 2
getfield io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing.message:Lio/netty/handler/codec/http/HttpMessage;
instanceof io.micronaut.http.netty.stream.StreamedHttpMessage
ifeq 11
5: aload 2
getfield io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing.message:Lio/netty/handler/codec/http/HttpMessage;
checkcast io.micronaut.http.netty.stream.StreamedHttpMessage
astore 3
start local 3 6: new io.micronaut.http.netty.stream.HttpStreamsHandler$3
dup
aload 0
aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.executor:()Lio/netty/util/concurrent/EventExecutor;
aload 1
invokespecial io.micronaut.http.netty.stream.HttpStreamsHandler$3.<init>:(Lio/micronaut/http/netty/stream/HttpStreamsHandler;Lio/netty/util/concurrent/EventExecutor;Lio/netty/channel/ChannelHandlerContext;)V
astore 4
start local 4 7: aload 0
iconst_1
putfield io.micronaut.http.netty.stream.HttpStreamsHandler.sendLastHttpContent:Z
8: aload 1
aload 2
getfield io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing.message:Lio/netty/handler/codec/http/HttpMessage;
invokeinterface io.netty.channel.ChannelHandlerContext.writeAndFlush:(Ljava/lang/Object;)Lio/netty/channel/ChannelFuture;
pop
9: aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.name:()Ljava/lang/String;
new java.lang.StringBuilder
dup
aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.name:()Ljava/lang/String;
invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
ldc "-body-subscriber"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
aload 4
invokeinterface io.netty.channel.ChannelPipeline.addAfter:(Ljava/lang/String;Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
pop
10: aload 0
aload 3
aload 4
invokevirtual io.micronaut.http.netty.stream.HttpStreamsHandler.subscribeSubscriberToStream:(Lio/micronaut/http/netty/stream/StreamedHttpMessage;Lorg/reactivestreams/Subscriber;)V
end local 4 end local 3 11: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lio/micronaut/http/netty/stream/HttpStreamsHandler<TIn;TOut;>;
0 12 1 ctx Lio/netty/channel/ChannelHandlerContext;
0 12 2 out Lio/micronaut/http/netty/stream/HttpStreamsHandler<TIn;TOut;>.Outgoing;
6 11 3 streamed Lio/micronaut/http/netty/stream/StreamedHttpMessage;
7 11 4 subscriber Lio/micronaut/http/netty/reactive/HandlerSubscriber<Lio/netty/handler/codec/http/HttpContent;>;
Signature: (Lio/netty/channel/ChannelHandlerContext;Lio/micronaut/http/netty/stream/HttpStreamsHandler<TIn;TOut;>.Outgoing;)V
MethodParameters:
Name Flags
ctx final
out final
private void completeBody(io.netty.channel.ChannelHandlerContext);
descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=3, args_size=2
start local 0 start local 1 0: aload 0
aload 1
new java.lang.StringBuilder
dup
aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.name:()Ljava/lang/String;
invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
ldc "-body-subscriber"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual io.micronaut.http.netty.stream.HttpStreamsHandler.removeHandlerIfActive:(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/String;)V
1: aload 0
getfield io.micronaut.http.netty.stream.HttpStreamsHandler.sendLastHttpContent:Z
ifeq 8
2: aload 0
getfield io.micronaut.http.netty.stream.HttpStreamsHandler.outgoing:Ljava/util/Queue;
invokeinterface java.util.Queue.peek:()Ljava/lang/Object;
checkcast io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing
getfield io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing.promise:Lio/netty/channel/ChannelPromise;
astore 2
start local 2 3: aload 1
getstatic io.netty.handler.codec.http.LastHttpContent.EMPTY_LAST_CONTENT:Lio/netty/handler/codec/http/LastHttpContent;
aload 2
invokeinterface io.netty.channel.ChannelHandlerContext.writeAndFlush:(Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture;
4: aload 0
aload 1
invokedynamic operationComplete(Lio/micronaut/http/netty/stream/HttpStreamsHandler;Lio/netty/channel/ChannelHandlerContext;)Lio/netty/util/concurrent/GenericFutureListener;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Lio/netty/util/concurrent/Future;)V
io/micronaut/http/netty/stream/HttpStreamsHandler.lambda$2(Lio/netty/channel/ChannelHandlerContext;Lio/netty/util/concurrent/Future;)V (7)
(Lio/netty/util/concurrent/Future;)V
5: invokeinterface io.netty.channel.ChannelFuture.addListener:(Lio/netty/util/concurrent/GenericFutureListener;)Lio/netty/channel/ChannelFuture;
pop
6: aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.read:()Lio/netty/channel/ChannelHandlerContext;
pop
end local 2 7: goto 12
8: StackMap locals:
StackMap stack:
aload 0
getfield io.micronaut.http.netty.stream.HttpStreamsHandler.outgoing:Ljava/util/Queue;
invokeinterface java.util.Queue.remove:()Ljava/lang/Object;
checkcast io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing
getfield io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing.promise:Lio/netty/channel/ChannelPromise;
invokeinterface io.netty.channel.ChannelPromise.setSuccess:()Lio/netty/channel/ChannelPromise;
pop
9: aload 0
aload 1
invokevirtual io.micronaut.http.netty.stream.HttpStreamsHandler.sentOutMessage:(Lio/netty/channel/ChannelHandlerContext;)V
10: aload 0
aload 1
invokevirtual io.micronaut.http.netty.stream.HttpStreamsHandler.flushNext:(Lio/netty/channel/ChannelHandlerContext;)V
11: aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.read:()Lio/netty/channel/ChannelHandlerContext;
pop
12: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lio/micronaut/http/netty/stream/HttpStreamsHandler<TIn;TOut;>;
0 13 1 ctx Lio/netty/channel/ChannelHandlerContext;
3 7 2 promise Lio/netty/channel/ChannelPromise;
MethodParameters:
Name Flags
ctx final
private void removeHandlerIfActive(io.netty.channel.ChannelHandlerContext, java.lang.String);
descriptor: (Lio/netty/channel/ChannelHandlerContext;Ljava/lang/String;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.channel:()Lio/netty/channel/Channel;
invokeinterface io.netty.channel.Channel.isActive:()Z
ifeq 5
1: aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
astore 3
start local 3 2: aload 3
aload 2
invokeinterface io.netty.channel.ChannelPipeline.get:(Ljava/lang/String;)Lio/netty/channel/ChannelHandler;
astore 4
start local 4 3: aload 4
ifnull 5
4: aload 3
aload 2
invokeinterface io.netty.channel.ChannelPipeline.remove:(Ljava/lang/String;)Lio/netty/channel/ChannelHandler;
pop
end local 4 end local 3 5: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/micronaut/http/netty/stream/HttpStreamsHandler<TIn;TOut;>;
0 6 1 ctx Lio/netty/channel/ChannelHandlerContext;
0 6 2 name Ljava/lang/String;
2 5 3 pipeline Lio/netty/channel/ChannelPipeline;
3 5 4 handler Lio/netty/channel/ChannelHandler;
MethodParameters:
Name Flags
ctx
name
private void flushNext(io.netty.channel.ChannelHandlerContext);
descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.micronaut.http.netty.stream.HttpStreamsHandler.outgoing:Ljava/util/Queue;
invokeinterface java.util.Queue.isEmpty:()Z
ifne 3
1: aload 0
aload 1
aload 0
getfield io.micronaut.http.netty.stream.HttpStreamsHandler.outgoing:Ljava/util/Queue;
invokeinterface java.util.Queue.element:()Ljava/lang/Object;
checkcast io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing
invokevirtual io.micronaut.http.netty.stream.HttpStreamsHandler.unbufferedWrite:(Lio/netty/channel/ChannelHandlerContext;Lio/micronaut/http/netty/stream/HttpStreamsHandler$Outgoing;)V
2: goto 4
3: StackMap locals:
StackMap stack:
aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.fireChannelWritabilityChanged:()Lio/netty/channel/ChannelHandlerContext;
pop
4: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/micronaut/http/netty/stream/HttpStreamsHandler<TIn;TOut;>;
0 5 1 ctx Lio/netty/channel/ChannelHandlerContext;
MethodParameters:
Name Flags
ctx
private void executeInEventLoop(io.netty.channel.ChannelHandlerContext, java.lang.Runnable);
descriptor: (Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Runnable;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.executor:()Lio/netty/util/concurrent/EventExecutor;
invokeinterface io.netty.util.concurrent.EventExecutor.inEventLoop:()Z
ifeq 3
1: aload 2
invokeinterface java.lang.Runnable.run:()V
2: goto 4
3: StackMap locals:
StackMap stack:
aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.executor:()Lio/netty/util/concurrent/EventExecutor;
aload 2
invokeinterface io.netty.util.concurrent.EventExecutor.execute:(Ljava/lang/Runnable;)V
4: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/micronaut/http/netty/stream/HttpStreamsHandler<TIn;TOut;>;
0 5 1 ctx Lio/netty/channel/ChannelHandlerContext;
0 5 2 runnable Ljava/lang/Runnable;
MethodParameters:
Name Flags
ctx
runnable
protected boolean isValidOutMessage(java.lang.Object);
descriptor: (Ljava/lang/Object;)Z
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.micronaut.http.netty.stream.HttpStreamsHandler.outClass:Ljava/lang/Class;
aload 1
invokevirtual java.lang.Class.isInstance:(Ljava/lang/Object;)Z
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/micronaut/http/netty/stream/HttpStreamsHandler<TIn;TOut;>;
0 1 1 msg Ljava/lang/Object;
MethodParameters:
Name Flags
msg
protected boolean isValidInMessage(java.lang.Object);
descriptor: (Ljava/lang/Object;)Z
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.micronaut.http.netty.stream.HttpStreamsHandler.inClass:Ljava/lang/Class;
aload 1
invokevirtual java.lang.Class.isInstance:(Ljava/lang/Object;)Z
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/micronaut/http/netty/stream/HttpStreamsHandler<TIn;TOut;>;
0 1 1 msg Ljava/lang/Object;
MethodParameters:
Name Flags
msg
private void lambda$0(io.netty.channel.ChannelHandlerContext, io.netty.util.concurrent.Future);
descriptor: (Lio/netty/channel/ChannelHandlerContext;Lio/netty/util/concurrent/Future;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 2 0: aload 0
aload 1
aload 0
aload 1
invokedynamic run(Lio/micronaut/http/netty/stream/HttpStreamsHandler;Lio/netty/channel/ChannelHandlerContext;)Ljava/lang/Runnable;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()V
io/micronaut/http/netty/stream/HttpStreamsHandler.lambda$1(Lio/netty/channel/ChannelHandlerContext;)V (7)
()V
invokevirtual io.micronaut.http.netty.stream.HttpStreamsHandler.executeInEventLoop:(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Runnable;)V
1: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/micronaut/http/netty/stream/HttpStreamsHandler<TIn;TOut;>;
0 2 2 channelFuture Lio/netty/util/concurrent/Future<-Ljava/lang/Void;>;
Exceptions:
throws java.lang.Exception
private void lambda$2(io.netty.channel.ChannelHandlerContext, io.netty.util.concurrent.Future);
descriptor: (Lio/netty/channel/ChannelHandlerContext;Lio/netty/util/concurrent/Future;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 2 0: aload 0
aload 1
aload 0
aload 1
invokedynamic run(Lio/micronaut/http/netty/stream/HttpStreamsHandler;Lio/netty/channel/ChannelHandlerContext;)Ljava/lang/Runnable;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()V
io/micronaut/http/netty/stream/HttpStreamsHandler.lambda$3(Lio/netty/channel/ChannelHandlerContext;)V (7)
()V
invokevirtual io.micronaut.http.netty.stream.HttpStreamsHandler.executeInEventLoop:(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Runnable;)V
1: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/micronaut/http/netty/stream/HttpStreamsHandler<TIn;TOut;>;
0 2 2 channelFuture Lio/netty/util/concurrent/Future<-Ljava/lang/Void;>;
Exceptions:
throws java.lang.Exception
private void lambda$1(io.netty.channel.ChannelHandlerContext);
descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 0 0: aload 0
aload 1
invokevirtual io.micronaut.http.netty.stream.HttpStreamsHandler.sentOutMessage:(Lio/netty/channel/ChannelHandlerContext;)V
1: aload 0
getfield io.micronaut.http.netty.stream.HttpStreamsHandler.outgoing:Ljava/util/Queue;
invokeinterface java.util.Queue.remove:()Ljava/lang/Object;
pop
2: aload 0
aload 1
invokevirtual io.micronaut.http.netty.stream.HttpStreamsHandler.flushNext:(Lio/netty/channel/ChannelHandlerContext;)V
3: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/micronaut/http/netty/stream/HttpStreamsHandler<TIn;TOut;>;
private void lambda$3(io.netty.channel.ChannelHandlerContext);
descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 0 0: aload 0
getfield io.micronaut.http.netty.stream.HttpStreamsHandler.outgoing:Ljava/util/Queue;
invokeinterface java.util.Queue.remove:()Ljava/lang/Object;
pop
1: aload 0
aload 1
invokevirtual io.micronaut.http.netty.stream.HttpStreamsHandler.sentOutMessage:(Lio/netty/channel/ChannelHandlerContext;)V
2: aload 0
aload 1
invokevirtual io.micronaut.http.netty.stream.HttpStreamsHandler.flushNext:(Lio/netty/channel/ChannelHandlerContext;)V
3: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/micronaut/http/netty/stream/HttpStreamsHandler<TIn;TOut;>;
}
Signature: <In::Lio/netty/handler/codec/http/HttpMessage;Out::Lio/netty/handler/codec/http/HttpMessage;>Lio/netty/channel/ChannelDuplexHandler;
SourceFile: "HttpStreamsHandler.java"
NestMembers:
io.micronaut.http.netty.stream.HttpStreamsHandler$1 io.micronaut.http.netty.stream.HttpStreamsHandler$2 io.micronaut.http.netty.stream.HttpStreamsHandler$3 io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing
InnerClasses:
io.micronaut.http.netty.stream.HttpStreamsHandler$1
io.micronaut.http.netty.stream.HttpStreamsHandler$2
io.micronaut.http.netty.stream.HttpStreamsHandler$3
Outgoing = io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing of io.micronaut.http.netty.stream.HttpStreamsHandler
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
RuntimeVisibleAnnotations:
io.micronaut.core.annotation.Internal()