public abstract class org.jboss.resteasy.core.AsyncResponseConsumer
minor version: 0
major version: 59
flags: flags: (0x0421) ACC_PUBLIC, ACC_SUPER, ACC_ABSTRACT
this_class: org.jboss.resteasy.core.AsyncResponseConsumer
super_class: java.lang.Object
{
protected java.util.Map<java.lang.Class<?>, java.lang.Object> contextDataMap;
descriptor: Ljava/util/Map;
flags: (0x0004) ACC_PROTECTED
Signature: Ljava/util/Map<Ljava/lang/Class<*>;Ljava/lang/Object;>;
protected org.jboss.resteasy.core.ResourceMethodInvoker method;
descriptor: Lorg/jboss/resteasy/core/ResourceMethodInvoker;
flags: (0x0004) ACC_PROTECTED
protected org.jboss.resteasy.core.SynchronousDispatcher dispatcher;
descriptor: Lorg/jboss/resteasy/core/SynchronousDispatcher;
flags: (0x0004) ACC_PROTECTED
protected org.jboss.resteasy.spi.ResteasyAsynchronousResponse asyncResponse;
descriptor: Lorg/jboss/resteasy/spi/ResteasyAsynchronousResponse;
flags: (0x0004) ACC_PROTECTED
protected boolean isComplete;
descriptor: Z
flags: (0x0004) ACC_PROTECTED
public void <init>(org.jboss.resteasy.core.ResourceMethodInvoker);
descriptor: (Lorg/jboss/resteasy/core/ResourceMethodInvoker;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 1
putfield org.jboss.resteasy.core.AsyncResponseConsumer.method:Lorg/jboss/resteasy/core/ResourceMethodInvoker;
2: aload 0
invokestatic org.jboss.resteasy.spi.ResteasyProviderFactory.getContextDataMap:()Ljava/util/Map;
putfield org.jboss.resteasy.core.AsyncResponseConsumer.contextDataMap:Ljava/util/Map;
3: aload 0
aload 0
getfield org.jboss.resteasy.core.AsyncResponseConsumer.contextDataMap:Ljava/util/Map;
ldc Lorg/jboss/resteasy/core/Dispatcher;
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.jboss.resteasy.core.SynchronousDispatcher
putfield org.jboss.resteasy.core.AsyncResponseConsumer.dispatcher:Lorg/jboss/resteasy/core/SynchronousDispatcher;
4: aload 0
getfield org.jboss.resteasy.core.AsyncResponseConsumer.contextDataMap:Ljava/util/Map;
ldc Lorg/jboss/resteasy/spi/HttpRequest;
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.jboss.resteasy.spi.HttpRequest
astore 2
start local 2 5: aload 2
invokeinterface org.jboss.resteasy.spi.HttpRequest.getAsyncContext:()Lorg/jboss/resteasy/spi/ResteasyAsynchronousContext;
invokeinterface org.jboss.resteasy.spi.ResteasyAsynchronousContext.isSuspended:()Z
ifeq 7
6: aload 0
aload 2
invokeinterface org.jboss.resteasy.spi.HttpRequest.getAsyncContext:()Lorg/jboss/resteasy/spi/ResteasyAsynchronousContext;
invokeinterface org.jboss.resteasy.spi.ResteasyAsynchronousContext.getAsyncResponse:()Lorg/jboss/resteasy/spi/ResteasyAsynchronousResponse;
putfield org.jboss.resteasy.core.AsyncResponseConsumer.asyncResponse:Lorg/jboss/resteasy/spi/ResteasyAsynchronousResponse;
goto 8
7: StackMap locals: org.jboss.resteasy.core.AsyncResponseConsumer org.jboss.resteasy.core.ResourceMethodInvoker org.jboss.resteasy.spi.HttpRequest
StackMap stack:
aload 0
aload 2
invokeinterface org.jboss.resteasy.spi.HttpRequest.getAsyncContext:()Lorg/jboss/resteasy/spi/ResteasyAsynchronousContext;
invokeinterface org.jboss.resteasy.spi.ResteasyAsynchronousContext.suspend:()Lorg/jboss/resteasy/spi/ResteasyAsynchronousResponse;
putfield org.jboss.resteasy.core.AsyncResponseConsumer.asyncResponse:Lorg/jboss/resteasy/spi/ResteasyAsynchronousResponse;
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 Lorg/jboss/resteasy/core/AsyncResponseConsumer;
0 9 1 method Lorg/jboss/resteasy/core/ResourceMethodInvoker;
5 9 2 httpRequest Lorg/jboss/resteasy/spi/HttpRequest;
MethodParameters:
Name Flags
method final
public static org.jboss.resteasy.core.AsyncResponseConsumer makeAsyncResponseConsumer(org.jboss.resteasy.core.ResourceMethodInvoker, org.jboss.resteasy.spi.AsyncResponseProvider<?>);
descriptor: (Lorg/jboss/resteasy/core/ResourceMethodInvoker;Lorg/jboss/resteasy/spi/AsyncResponseProvider;)Lorg/jboss/resteasy/core/AsyncResponseConsumer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: new org.jboss.resteasy.core.AsyncResponseConsumer$CompletionStageResponseConsumer
dup
aload 0
aload 1
invokespecial org.jboss.resteasy.core.AsyncResponseConsumer$CompletionStageResponseConsumer.<init>:(Lorg/jboss/resteasy/core/ResourceMethodInvoker;Lorg/jboss/resteasy/spi/AsyncResponseProvider;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 method Lorg/jboss/resteasy/core/ResourceMethodInvoker;
0 1 1 asyncResponseProvider Lorg/jboss/resteasy/spi/AsyncResponseProvider<*>;
Signature: (Lorg/jboss/resteasy/core/ResourceMethodInvoker;Lorg/jboss/resteasy/spi/AsyncResponseProvider<*>;)Lorg/jboss/resteasy/core/AsyncResponseConsumer;
MethodParameters:
Name Flags
method
asyncResponseProvider
public static org.jboss.resteasy.core.AsyncResponseConsumer makeAsyncResponseConsumer(org.jboss.resteasy.core.ResourceMethodInvoker, org.jboss.resteasy.spi.AsyncStreamProvider<?>);
descriptor: (Lorg/jboss/resteasy/core/ResourceMethodInvoker;Lorg/jboss/resteasy/spi/AsyncStreamProvider;)Lorg/jboss/resteasy/core/AsyncResponseConsumer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.jboss.resteasy.core.ResourceMethodInvoker.isSse:()Z
ifeq 2
1: new org.jboss.resteasy.core.AsyncResponseConsumer$AsyncGeneralStreamingSseResponseConsumer
dup
aload 0
aload 1
invokespecial org.jboss.resteasy.core.AsyncResponseConsumer$AsyncGeneralStreamingSseResponseConsumer.<init>:(Lorg/jboss/resteasy/core/ResourceMethodInvoker;Lorg/jboss/resteasy/spi/AsyncStreamProvider;)V
areturn
2: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.jboss.resteasy.core.ResourceMethodInvoker.getMethod:()Ljava/lang/reflect/Method;
ldc Lorg/jboss/resteasy/annotations/Stream;
invokevirtual java.lang.reflect.Method.getAnnotation:(Ljava/lang/Class;)Ljava/lang/annotation/Annotation;
checkcast org.jboss.resteasy.annotations.Stream
astore 2
start local 2 3: aload 2
ifnull 7
4: getstatic org.jboss.resteasy.annotations.Stream$MODE.RAW:Lorg/jboss/resteasy/annotations/Stream$MODE;
aload 2
invokeinterface org.jboss.resteasy.annotations.Stream.value:()Lorg/jboss/resteasy/annotations/Stream$MODE;
invokevirtual org.jboss.resteasy.annotations.Stream$MODE.equals:(Ljava/lang/Object;)Z
ifeq 6
5: new org.jboss.resteasy.core.AsyncResponseConsumer$AsyncRawStreamingResponseConsumer
dup
aload 0
aload 1
invokespecial org.jboss.resteasy.core.AsyncResponseConsumer$AsyncRawStreamingResponseConsumer.<init>:(Lorg/jboss/resteasy/core/ResourceMethodInvoker;Lorg/jboss/resteasy/spi/AsyncStreamProvider;)V
areturn
6: StackMap locals: org.jboss.resteasy.annotations.Stream
StackMap stack:
new org.jboss.resteasy.core.AsyncResponseConsumer$AsyncGeneralStreamingSseResponseConsumer
dup
aload 0
aload 1
invokespecial org.jboss.resteasy.core.AsyncResponseConsumer$AsyncGeneralStreamingSseResponseConsumer.<init>:(Lorg/jboss/resteasy/core/ResourceMethodInvoker;Lorg/jboss/resteasy/spi/AsyncStreamProvider;)V
areturn
7: StackMap locals:
StackMap stack:
new org.jboss.resteasy.core.AsyncResponseConsumer$AsyncStreamCollectorResponseConsumer
dup
aload 0
aload 1
invokespecial org.jboss.resteasy.core.AsyncResponseConsumer$AsyncStreamCollectorResponseConsumer.<init>:(Lorg/jboss/resteasy/core/ResourceMethodInvoker;Lorg/jboss/resteasy/spi/AsyncStreamProvider;)V
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 method Lorg/jboss/resteasy/core/ResourceMethodInvoker;
0 8 1 asyncStreamProvider Lorg/jboss/resteasy/spi/AsyncStreamProvider<*>;
3 8 2 stream Lorg/jboss/resteasy/annotations/Stream;
Signature: (Lorg/jboss/resteasy/core/ResourceMethodInvoker;Lorg/jboss/resteasy/spi/AsyncStreamProvider<*>;)Lorg/jboss/resteasy/core/AsyncResponseConsumer;
MethodParameters:
Name Flags
method
asyncStreamProvider
protected void doComplete();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.jboss.resteasy.core.AsyncResponseConsumer.asyncResponse:Lorg/jboss/resteasy/spi/ResteasyAsynchronousResponse;
invokeinterface org.jboss.resteasy.spi.ResteasyAsynchronousResponse.complete:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/jboss/resteasy/core/AsyncResponseConsumer;
public final synchronized void complete(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SYNCHRONIZED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.jboss.resteasy.core.AsyncResponseConsumer.isComplete:Z
ifne 5
1: aload 0
iconst_1
putfield org.jboss.resteasy.core.AsyncResponseConsumer.isComplete:Z
2: aload 0
invokevirtual org.jboss.resteasy.core.AsyncResponseConsumer.doComplete:()V
3: aload 0
getfield org.jboss.resteasy.core.AsyncResponseConsumer.asyncResponse:Lorg/jboss/resteasy/spi/ResteasyAsynchronousResponse;
aload 1
invokeinterface org.jboss.resteasy.spi.ResteasyAsynchronousResponse.completionCallbacks:(Ljava/lang/Throwable;)V
4: invokestatic org.jboss.resteasy.spi.ResteasyProviderFactory.removeContextDataLevel:()V
5: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/jboss/resteasy/core/AsyncResponseConsumer;
0 6 1 t Ljava/lang/Throwable;
MethodParameters:
Name Flags
t
protected void internalResume(, java.util.function.Consumer<java.lang.Throwable>);
descriptor: (Ljava/lang/Object;Ljava/util/function/Consumer;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=6, locals=10, args_size=3
start local 0 start local 1 start local 2 0: aconst_null
astore 3
aconst_null
astore 4
1: aload 0
getfield org.jboss.resteasy.core.AsyncResponseConsumer.contextDataMap:Ljava/util/Map;
invokestatic org.jboss.resteasy.spi.ResteasyProviderFactory.addCloseableContextDataLevel:(Ljava/util/Map;)Lorg/jboss/resteasy/spi/ResteasyProviderFactory$CloseableContext;
astore 5
start local 5 2: aload 0
getfield org.jboss.resteasy.core.AsyncResponseConsumer.contextDataMap:Ljava/util/Map;
ldc Lorg/jboss/resteasy/spi/HttpRequest;
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.jboss.resteasy.spi.HttpRequest
astore 6
start local 6 3: aload 0
getfield org.jboss.resteasy.core.AsyncResponseConsumer.contextDataMap:Ljava/util/Map;
ldc Lorg/jboss/resteasy/spi/HttpResponse;
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.jboss.resteasy.spi.HttpResponse
astore 7
start local 7 4: aload 0
aload 1
aload 6
invokevirtual org.jboss.resteasy.core.AsyncResponseConsumer.createResponse:(Ljava/lang/Object;Lorg/jboss/resteasy/spi/HttpRequest;)Lorg/jboss/resteasy/specimpl/BuiltResponse;
astore 8
start local 8 5: aload 0
aload 8
aload 6
aload 7
aload 0
aload 2
invokedynamic accept(Lorg/jboss/resteasy/core/AsyncResponseConsumer;Ljava/util/function/Consumer;)Ljava/util/function/Consumer;
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:
(Ljava/lang/Object;)V
org/jboss/resteasy/core/AsyncResponseConsumer.lambda$0(Ljava/util/function/Consumer;Ljava/lang/Throwable;)V (7)
(Ljava/lang/Throwable;)V
invokevirtual org.jboss.resteasy.core.AsyncResponseConsumer.sendBuiltResponse:(Lorg/jboss/resteasy/specimpl/BuiltResponse;Lorg/jboss/resteasy/spi/HttpRequest;Lorg/jboss/resteasy/spi/HttpResponse;Ljava/util/function/Consumer;)V
6: goto 10
StackMap locals: org.jboss.resteasy.core.AsyncResponseConsumer java.lang.Object java.util.function.Consumer java.lang.Throwable java.lang.Throwable org.jboss.resteasy.spi.ResteasyProviderFactory$CloseableContext org.jboss.resteasy.spi.HttpRequest org.jboss.resteasy.spi.HttpResponse org.jboss.resteasy.specimpl.BuiltResponse
StackMap stack: java.lang.Throwable
7: astore 9
start local 9 8: aload 0
aload 9
invokevirtual org.jboss.resteasy.core.AsyncResponseConsumer.exceptionWhileResuming:(Ljava/lang/Throwable;)V
9: aload 2
aload 9
invokeinterface java.util.function.Consumer.accept:(Ljava/lang/Object;)V
end local 9 end local 8 end local 7 end local 6 10: StackMap locals:
StackMap stack:
aload 5
ifnull 16
aload 5
invokeinterface org.jboss.resteasy.spi.ResteasyProviderFactory$CloseableContext.close:()V
goto 16
StackMap locals:
StackMap stack: java.lang.Throwable
11: astore 3
aload 5
ifnull 12
aload 5
invokeinterface org.jboss.resteasy.spi.ResteasyProviderFactory$CloseableContext.close:()V
end local 5 StackMap locals:
StackMap stack:
12: aload 3
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
13: astore 4
aload 3
ifnonnull 14
aload 4
astore 3
goto 15
StackMap locals:
StackMap stack:
14: aload 3
aload 4
if_acmpeq 15
aload 3
aload 4
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
15: aload 3
athrow
16: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 17 0 this Lorg/jboss/resteasy/core/AsyncResponseConsumer;
0 17 1 entity Ljava/lang/Object;
0 17 2 onComplete Ljava/util/function/Consumer<Ljava/lang/Throwable;>;
2 12 5 c Lorg/jboss/resteasy/spi/ResteasyProviderFactory$CloseableContext;
3 10 6 httpRequest Lorg/jboss/resteasy/spi/HttpRequest;
4 10 7 httpResponse Lorg/jboss/resteasy/spi/HttpResponse;
5 10 8 builtResponse Lorg/jboss/resteasy/specimpl/BuiltResponse;
8 10 9 e Ljava/lang/Throwable;
Exception table:
from to target type
5 6 7 Class java.lang.Throwable
2 10 11 any
1 13 13 any
Signature: (Ljava/lang/Object;Ljava/util/function/Consumer<Ljava/lang/Throwable;>;)V
MethodParameters:
Name Flags
entity
onComplete
private void exceptionWhileResuming(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokedynamic accept()Ljava/util/function/Consumer;
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:
(Ljava/lang/Object;)V
org/jboss/resteasy/core/AsyncResponseConsumer.lambda$1(Ljava/lang/Throwable;)V (6)
(Ljava/lang/Throwable;)V
invokevirtual org.jboss.resteasy.core.AsyncResponseConsumer.internalResume:(Ljava/lang/Throwable;Ljava/util/function/Consumer;)V
1: goto 3
2: StackMap locals:
StackMap stack: java.lang.Throwable
pop
3: StackMap locals:
StackMap stack:
aload 0
aload 1
invokevirtual org.jboss.resteasy.core.AsyncResponseConsumer.complete:(Ljava/lang/Throwable;)V
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/jboss/resteasy/core/AsyncResponseConsumer;
0 5 1 e Ljava/lang/Throwable;
Exception table:
from to target type
0 1 2 Class java.lang.Throwable
MethodParameters:
Name Flags
e
protected void sendBuiltResponse(org.jboss.resteasy.specimpl.BuiltResponse, org.jboss.resteasy.spi.HttpRequest, org.jboss.resteasy.spi.HttpResponse, java.util.function.Consumer<java.lang.Throwable>);
descriptor: (Lorg/jboss/resteasy/specimpl/BuiltResponse;Lorg/jboss/resteasy/spi/HttpRequest;Lorg/jboss/resteasy/spi/HttpResponse;Ljava/util/function/Consumer;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=6, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
invokevirtual org.jboss.resteasy.core.AsyncResponseConsumer.sendHeaders:()Z
istore 5
start local 5 1: aload 1
aload 2
aload 3
aload 0
getfield org.jboss.resteasy.core.AsyncResponseConsumer.dispatcher:Lorg/jboss/resteasy/core/SynchronousDispatcher;
invokevirtual org.jboss.resteasy.core.SynchronousDispatcher.getProviderFactory:()Lorg/jboss/resteasy/spi/ResteasyProviderFactory;
aload 4
iload 5
invokestatic org.jboss.resteasy.core.ServerResponseWriter.writeNomapResponse:(Lorg/jboss/resteasy/specimpl/BuiltResponse;Lorg/jboss/resteasy/spi/HttpRequest;Lorg/jboss/resteasy/spi/HttpResponse;Lorg/jboss/resteasy/spi/ResteasyProviderFactory;Ljava/util/function/Consumer;Z)V
2: return
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/jboss/resteasy/core/AsyncResponseConsumer;
0 3 1 builtResponse Lorg/jboss/resteasy/specimpl/BuiltResponse;
0 3 2 httpRequest Lorg/jboss/resteasy/spi/HttpRequest;
0 3 3 httpResponse Lorg/jboss/resteasy/spi/HttpResponse;
0 3 4 onComplete Ljava/util/function/Consumer<Ljava/lang/Throwable;>;
1 3 5 sendHeaders Z
Exceptions:
throws java.io.IOException
Signature: (Lorg/jboss/resteasy/specimpl/BuiltResponse;Lorg/jboss/resteasy/spi/HttpRequest;Lorg/jboss/resteasy/spi/HttpResponse;Ljava/util/function/Consumer<Ljava/lang/Throwable;>;)V
MethodParameters:
Name Flags
builtResponse
httpRequest
httpResponse
onComplete
protected abstract boolean ();
descriptor: ()Z
flags: (0x0404) ACC_PROTECTED, ACC_ABSTRACT
protected void internalResume(java.lang.Throwable, java.util.function.Consumer<java.lang.Throwable>);
descriptor: (Ljava/lang/Throwable;Ljava/util/function/Consumer;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=5, locals=8, args_size=3
start local 0 start local 1 start local 2 0: aconst_null
astore 3
aconst_null
astore 4
1: aload 0
getfield org.jboss.resteasy.core.AsyncResponseConsumer.contextDataMap:Ljava/util/Map;
invokestatic org.jboss.resteasy.spi.ResteasyProviderFactory.addCloseableContextDataLevel:(Ljava/util/Map;)Lorg/jboss/resteasy/spi/ResteasyProviderFactory$CloseableContext;
astore 5
start local 5 2: aload 0
getfield org.jboss.resteasy.core.AsyncResponseConsumer.contextDataMap:Ljava/util/Map;
ldc Lorg/jboss/resteasy/spi/HttpRequest;
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.jboss.resteasy.spi.HttpRequest
astore 6
start local 6 3: aload 0
getfield org.jboss.resteasy.core.AsyncResponseConsumer.contextDataMap:Ljava/util/Map;
ldc Lorg/jboss/resteasy/spi/HttpResponse;
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.jboss.resteasy.spi.HttpResponse
astore 7
start local 7 4: aload 0
getfield org.jboss.resteasy.core.AsyncResponseConsumer.dispatcher:Lorg/jboss/resteasy/core/SynchronousDispatcher;
aload 6
aload 7
aload 1
aload 2
invokevirtual org.jboss.resteasy.core.SynchronousDispatcher.writeException:(Lorg/jboss/resteasy/spi/HttpRequest;Lorg/jboss/resteasy/spi/HttpResponse;Ljava/lang/Throwable;Ljava/util/function/Consumer;)V
5: goto 9
StackMap locals: org.jboss.resteasy.core.AsyncResponseConsumer java.lang.Throwable java.util.function.Consumer java.lang.Throwable java.lang.Throwable org.jboss.resteasy.spi.ResteasyProviderFactory$CloseableContext org.jboss.resteasy.spi.HttpRequest org.jboss.resteasy.spi.HttpResponse
StackMap stack: java.lang.Throwable
6: pop
7: aload 0
getfield org.jboss.resteasy.core.AsyncResponseConsumer.dispatcher:Lorg/jboss/resteasy/core/SynchronousDispatcher;
aload 7
aload 1
invokevirtual org.jboss.resteasy.core.SynchronousDispatcher.unhandledAsynchronousException:(Lorg/jboss/resteasy/spi/HttpResponse;Ljava/lang/Throwable;)V
8: aload 2
aload 1
invokeinterface java.util.function.Consumer.accept:(Ljava/lang/Object;)V
end local 7 end local 6 9: StackMap locals:
StackMap stack:
aload 5
ifnull 15
aload 5
invokeinterface org.jboss.resteasy.spi.ResteasyProviderFactory$CloseableContext.close:()V
goto 15
StackMap locals:
StackMap stack: java.lang.Throwable
10: astore 3
aload 5
ifnull 11
aload 5
invokeinterface org.jboss.resteasy.spi.ResteasyProviderFactory$CloseableContext.close:()V
end local 5 StackMap locals:
StackMap stack:
11: aload 3
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
12: astore 4
aload 3
ifnonnull 13
aload 4
astore 3
goto 14
StackMap locals:
StackMap stack:
13: aload 3
aload 4
if_acmpeq 14
aload 3
aload 4
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
14: aload 3
athrow
15: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Lorg/jboss/resteasy/core/AsyncResponseConsumer;
0 16 1 t Ljava/lang/Throwable;
0 16 2 onComplete Ljava/util/function/Consumer<Ljava/lang/Throwable;>;
2 11 5 c Lorg/jboss/resteasy/spi/ResteasyProviderFactory$CloseableContext;
3 9 6 httpRequest Lorg/jboss/resteasy/spi/HttpRequest;
4 9 7 httpResponse Lorg/jboss/resteasy/spi/HttpResponse;
Exception table:
from to target type
4 5 6 Class java.lang.Throwable
2 9 10 any
1 12 12 any
Signature: (Ljava/lang/Throwable;Ljava/util/function/Consumer<Ljava/lang/Throwable;>;)V
MethodParameters:
Name Flags
t
onComplete
protected org.jboss.resteasy.specimpl.BuiltResponse createResponse(java.lang.Object, org.jboss.resteasy.spi.HttpRequest);
descriptor: (Ljava/lang/Object;Lorg/jboss/resteasy/spi/HttpRequest;)Lorg/jboss/resteasy/specimpl/BuiltResponse;
flags: (0x0004) ACC_PROTECTED
Code:
stack=7, locals=7, args_size=3
start local 0 start local 1 start local 2 0: aconst_null
astore 3
start local 3 1: aload 1
ifnonnull 4
2: invokestatic javax.ws.rs.core.Response.noContent:()Ljavax/ws/rs/core/Response$ResponseBuilder;
invokevirtual javax.ws.rs.core.Response$ResponseBuilder.build:()Ljavax/ws/rs/core/Response;
checkcast org.jboss.resteasy.specimpl.BuiltResponse
astore 3
3: goto 23
4: StackMap locals: org.jboss.resteasy.specimpl.BuiltResponse
StackMap stack:
aload 1
instanceof org.jboss.resteasy.specimpl.BuiltResponse
ifeq 7
5: aload 1
checkcast org.jboss.resteasy.specimpl.BuiltResponse
astore 3
6: goto 23
7: StackMap locals:
StackMap stack:
aload 1
instanceof javax.ws.rs.core.Response
ifeq 15
8: aload 1
checkcast javax.ws.rs.core.Response
astore 4
start local 4 9: new org.jboss.resteasy.core.Headers
dup
invokespecial org.jboss.resteasy.core.Headers.<init>:()V
astore 5
start local 5 10: aload 5
aload 4
invokevirtual javax.ws.rs.core.Response.getMetadata:()Ljavax/ws/rs/core/MultivaluedMap;
invokevirtual org.jboss.resteasy.core.Headers.putAll:(Ljava/util/Map;)V
11: new org.jboss.resteasy.specimpl.BuiltResponseEntityNotBacked
dup
aload 4
invokevirtual javax.ws.rs.core.Response.getStatus:()I
aload 4
invokevirtual javax.ws.rs.core.Response.getStatusInfo:()Ljavax/ws/rs/core/Response$StatusType;
invokeinterface javax.ws.rs.core.Response$StatusType.getReasonPhrase:()Ljava/lang/String;
12: aload 5
aload 4
invokevirtual javax.ws.rs.core.Response.getEntity:()Ljava/lang/Object;
aload 0
getfield org.jboss.resteasy.core.AsyncResponseConsumer.method:Lorg/jboss/resteasy/core/ResourceMethodInvoker;
invokevirtual org.jboss.resteasy.core.ResourceMethodInvoker.getMethodAnnotations:()[Ljava/lang/annotation/Annotation;
13: invokespecial org.jboss.resteasy.specimpl.BuiltResponseEntityNotBacked.<init>:(ILjava/lang/String;Lorg/jboss/resteasy/core/Headers;Ljava/lang/Object;[Ljava/lang/annotation/Annotation;)V
astore 3
end local 5 end local 4 14: goto 23
15: StackMap locals:
StackMap stack:
aload 0
getfield org.jboss.resteasy.core.AsyncResponseConsumer.method:Lorg/jboss/resteasy/core/ResourceMethodInvoker;
ifnonnull 17
16: new java.lang.IllegalStateException
dup
getstatic org.jboss.resteasy.resteasy_jaxrs.i18n.Messages.MESSAGES:Lorg/jboss/resteasy/resteasy_jaxrs/i18n/Messages;
invokeinterface org.jboss.resteasy.resteasy_jaxrs.i18n.Messages.unknownMediaTypeResponseEntity:()Ljava/lang/String;
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
17: StackMap locals:
StackMap stack:
aload 1
invokestatic javax.ws.rs.core.Response.ok:(Ljava/lang/Object;)Ljavax/ws/rs/core/Response$ResponseBuilder;
invokevirtual javax.ws.rs.core.Response$ResponseBuilder.build:()Ljavax/ws/rs/core/Response;
checkcast org.jboss.resteasy.specimpl.BuiltResponse
astore 4
start local 4 18: aload 0
getfield org.jboss.resteasy.core.AsyncResponseConsumer.method:Lorg/jboss/resteasy/core/ResourceMethodInvoker;
invokevirtual org.jboss.resteasy.core.ResourceMethodInvoker.getGenericReturnType:()Ljava/lang/reflect/Type;
checkcast java.lang.reflect.ParameterizedType
invokeinterface java.lang.reflect.ParameterizedType.getActualTypeArguments:()[Ljava/lang/reflect/Type;
iconst_0
aaload
astore 5
start local 5 19: aload 0
aload 5
invokevirtual org.jboss.resteasy.core.AsyncResponseConsumer.adaptGenericType:(Ljava/lang/reflect/Type;)Ljava/lang/reflect/Type;
astore 6
start local 6 20: aload 4
aload 6
invokevirtual org.jboss.resteasy.specimpl.BuiltResponse.setGenericType:(Ljava/lang/reflect/Type;)V
21: aload 4
aload 0
getfield org.jboss.resteasy.core.AsyncResponseConsumer.method:Lorg/jboss/resteasy/core/ResourceMethodInvoker;
invokevirtual org.jboss.resteasy.core.ResourceMethodInvoker.getMethodAnnotations:()[Ljava/lang/annotation/Annotation;
invokevirtual org.jboss.resteasy.specimpl.BuiltResponse.addMethodAnnotations:([Ljava/lang/annotation/Annotation;)V
22: aload 4
astore 3
end local 6 end local 5 end local 4 23: StackMap locals:
StackMap stack:
aload 3
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 24 0 this Lorg/jboss/resteasy/core/AsyncResponseConsumer;
0 24 1 entity Ljava/lang/Object;
0 24 2 httpRequest Lorg/jboss/resteasy/spi/HttpRequest;
1 24 3 builtResponse Lorg/jboss/resteasy/specimpl/BuiltResponse;
9 14 4 r Ljavax/ws/rs/core/Response;
10 14 5 metadata Lorg/jboss/resteasy/core/Headers<Ljava/lang/Object;>;
18 23 4 jaxrsResponse Lorg/jboss/resteasy/specimpl/BuiltResponse;
19 23 5 unwrappedType Ljava/lang/reflect/Type;
20 23 6 newType Ljava/lang/reflect/Type;
MethodParameters:
Name Flags
entity
httpRequest
protected java.lang.reflect.Type adaptGenericType(java.lang.reflect.Type);
descriptor: (Ljava/lang/reflect/Type;)Ljava/lang/reflect/Type;
flags: (0x0004) ACC_PROTECTED
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/jboss/resteasy/core/AsyncResponseConsumer;
0 1 1 unwrappedType Ljava/lang/reflect/Type;
MethodParameters:
Name Flags
unwrappedType
public abstract void subscribe(java.lang.Object);
descriptor: (Ljava/lang/Object;)V
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
MethodParameters:
Name Flags
rtn
private void lambda$0(java.util.function.Consumer, java.lang.Throwable);
descriptor: (Ljava/util/function/Consumer;Ljava/lang/Throwable;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 2 0: aload 2
ifnull 2
1: aload 0
aload 2
invokevirtual org.jboss.resteasy.core.AsyncResponseConsumer.exceptionWhileResuming:(Ljava/lang/Throwable;)V
2: StackMap locals:
StackMap stack:
aload 1
aload 2
invokeinterface java.util.function.Consumer.accept:(Ljava/lang/Object;)V
3: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/jboss/resteasy/core/AsyncResponseConsumer;
0 4 2 e Ljava/lang/Throwable;
private static void lambda$1(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=0, locals=1, args_size=1
start local 0 0: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 t Ljava/lang/Throwable;
}
SourceFile: "AsyncResponseConsumer.java"
NestMembers:
org.jboss.resteasy.core.AsyncResponseConsumer$AsyncGeneralStreamingSseResponseConsumer org.jboss.resteasy.core.AsyncResponseConsumer$AsyncRawStreamingResponseConsumer org.jboss.resteasy.core.AsyncResponseConsumer$AsyncStreamCollectorResponseConsumer org.jboss.resteasy.core.AsyncResponseConsumer$AsyncStreamCollectorResponseConsumer$1 org.jboss.resteasy.core.AsyncResponseConsumer$AsyncStreamResponseConsumer org.jboss.resteasy.core.AsyncResponseConsumer$CompletionStageResponseConsumer
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public abstract ResponseBuilder = javax.ws.rs.core.Response$ResponseBuilder of javax.ws.rs.core.Response
public abstract StatusType = javax.ws.rs.core.Response$StatusType of javax.ws.rs.core.Response
public final MODE = org.jboss.resteasy.annotations.Stream$MODE of org.jboss.resteasy.annotations.Stream
private AsyncGeneralStreamingSseResponseConsumer = org.jboss.resteasy.core.AsyncResponseConsumer$AsyncGeneralStreamingSseResponseConsumer of org.jboss.resteasy.core.AsyncResponseConsumer
private AsyncRawStreamingResponseConsumer = org.jboss.resteasy.core.AsyncResponseConsumer$AsyncRawStreamingResponseConsumer of org.jboss.resteasy.core.AsyncResponseConsumer
private AsyncStreamCollectorResponseConsumer = org.jboss.resteasy.core.AsyncResponseConsumer$AsyncStreamCollectorResponseConsumer of org.jboss.resteasy.core.AsyncResponseConsumer
private abstract AsyncStreamResponseConsumer = org.jboss.resteasy.core.AsyncResponseConsumer$AsyncStreamResponseConsumer of org.jboss.resteasy.core.AsyncResponseConsumer
private CompletionStageResponseConsumer = org.jboss.resteasy.core.AsyncResponseConsumer$CompletionStageResponseConsumer of org.jboss.resteasy.core.AsyncResponseConsumer
public abstract CloseableContext = org.jboss.resteasy.spi.ResteasyProviderFactory$CloseableContext of org.jboss.resteasy.spi.ResteasyProviderFactory