public class org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl extends javax.ws.rs.core.GenericType<javax.ws.rs.sse.OutboundSseEvent> implements javax.ws.rs.sse.SseEventSink
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl
super_class: javax.ws.rs.core.GenericType
{
private static final org.jboss.logging.Logger LOG;
descriptor: Lorg/jboss/logging/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private final javax.ws.rs.ext.MessageBodyWriter<javax.ws.rs.sse.OutboundSseEvent> writer;
descriptor: Ljavax/ws/rs/ext/MessageBodyWriter;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljavax/ws/rs/ext/MessageBodyWriter<Ljavax/ws/rs/sse/OutboundSseEvent;>;
private final org.jboss.resteasy.spi.ResteasyAsynchronousContext asyncContext;
descriptor: Lorg/jboss/resteasy/spi/ResteasyAsynchronousContext;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.jboss.resteasy.spi.HttpResponse response;
descriptor: Lorg/jboss/resteasy/spi/HttpResponse;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.jboss.resteasy.spi.HttpRequest request;
descriptor: Lorg/jboss/resteasy/spi/HttpRequest;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private volatile boolean closed;
descriptor: Z
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private final java.util.Map<java.lang.Class<?>, java.lang.Object> contextDataMap;
descriptor: Ljava/util/Map;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Map<Ljava/lang/Class<*>;Ljava/lang/Object;>;
private volatile boolean responseFlushed;
descriptor: Z
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private final java.lang.Object lock;
descriptor: Ljava/lang/Object;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.jboss.resteasy.spi.ResteasyProviderFactory providerFactory;
descriptor: Lorg/jboss/resteasy/spi/ResteasyProviderFactory;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Lorg/jboss/resteasy/plugins/providers/sse/SseEventOutputImpl;
invokestatic org.jboss.logging.Logger.getLogger:(Ljava/lang/Class;)Lorg/jboss/logging/Logger;
putstatic org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.LOG:Lorg/jboss/logging/Logger;
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(javax.ws.rs.ext.MessageBodyWriter<javax.ws.rs.sse.OutboundSseEvent>);
descriptor: (Ljavax/ws/rs/ext/MessageBodyWriter;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic org.jboss.resteasy.spi.ResteasyProviderFactory.getInstance:()Lorg/jboss/resteasy/spi/ResteasyProviderFactory;
invokespecial org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.<init>:(Ljavax/ws/rs/ext/MessageBodyWriter;Lorg/jboss/resteasy/spi/ResteasyProviderFactory;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/jboss/resteasy/plugins/providers/sse/SseEventOutputImpl;
0 2 1 writer Ljavax/ws/rs/ext/MessageBodyWriter<Ljavax/ws/rs/sse/OutboundSseEvent;>;
Signature: (Ljavax/ws/rs/ext/MessageBodyWriter<Ljavax/ws/rs/sse/OutboundSseEvent;>;)V
RuntimeVisibleAnnotations:
java.lang.Deprecated()
MethodParameters:
Name Flags
writer final
public void <init>(javax.ws.rs.ext.MessageBodyWriter<javax.ws.rs.sse.OutboundSseEvent>, org.jboss.resteasy.spi.ResteasyProviderFactory);
descriptor: (Ljavax/ws/rs/ext/MessageBodyWriter;Lorg/jboss/resteasy/spi/ResteasyProviderFactory;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokespecial javax.ws.rs.core.GenericType.<init>:()V
1: aload 0
iconst_0
putfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.responseFlushed:Z
2: aload 0
new java.lang.Object
dup
invokespecial java.lang.Object.<init>:()V
putfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.lock:Ljava/lang/Object;
3: aload 0
aload 1
putfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.writer:Ljavax/ws/rs/ext/MessageBodyWriter;
4: aload 0
invokestatic org.jboss.resteasy.core.ResteasyContext.getContextDataMap:()Ljava/util/Map;
putfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.contextDataMap:Ljava/util/Map;
5: aload 0
aload 2
putfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.providerFactory:Lorg/jboss/resteasy/spi/ResteasyProviderFactory;
6: aload 0
ldc Lorg/jboss/resteasy/spi/HttpRequest;
invokestatic org.jboss.resteasy.core.ResteasyContext.getContextData:(Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.jboss.resteasy.spi.HttpRequest
putfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.request:Lorg/jboss/resteasy/spi/HttpRequest;
7: aload 0
aload 0
getfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.request:Lorg/jboss/resteasy/spi/HttpRequest;
invokeinterface org.jboss.resteasy.spi.HttpRequest.getAsyncContext:()Lorg/jboss/resteasy/spi/ResteasyAsynchronousContext;
putfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.asyncContext:Lorg/jboss/resteasy/spi/ResteasyAsynchronousContext;
8: aload 0
getfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.asyncContext:Lorg/jboss/resteasy/spi/ResteasyAsynchronousContext;
invokeinterface org.jboss.resteasy.spi.ResteasyAsynchronousContext.isSuspended:()Z
ifne 13
9: aload 0
getfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.asyncContext:Lorg/jboss/resteasy/spi/ResteasyAsynchronousContext;
invokeinterface org.jboss.resteasy.spi.ResteasyAsynchronousContext.suspend:()Lorg/jboss/resteasy/spi/ResteasyAsynchronousResponse;
pop
10: goto 13
11: StackMap locals: org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl javax.ws.rs.ext.MessageBodyWriter org.jboss.resteasy.spi.ResteasyProviderFactory
StackMap stack: java.lang.IllegalStateException
pop
12: getstatic org.jboss.resteasy.resteasy_jaxrs.i18n.LogMessages.LOGGER:Lorg/jboss/resteasy/resteasy_jaxrs/i18n/LogMessages;
invokeinterface org.jboss.resteasy.resteasy_jaxrs.i18n.LogMessages.failedToSetRequestAsync:()V
13: StackMap locals:
StackMap stack:
aload 0
ldc Lorg/jboss/resteasy/spi/HttpResponse;
invokestatic org.jboss.resteasy.core.ResteasyContext.getContextData:(Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.jboss.resteasy.spi.HttpResponse
putfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.response:Lorg/jboss/resteasy/spi/HttpResponse;
14: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lorg/jboss/resteasy/plugins/providers/sse/SseEventOutputImpl;
0 15 1 writer Ljavax/ws/rs/ext/MessageBodyWriter<Ljavax/ws/rs/sse/OutboundSseEvent;>;
0 15 2 providerFactory Lorg/jboss/resteasy/spi/ResteasyProviderFactory;
Exception table:
from to target type
9 10 11 Class java.lang.IllegalStateException
Signature: (Ljavax/ws/rs/ext/MessageBodyWriter<Ljavax/ws/rs/sse/OutboundSseEvent;>;Lorg/jboss/resteasy/spi/ResteasyProviderFactory;)V
MethodParameters:
Name Flags
writer final
providerFactory final
public void close();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
iconst_1
invokevirtual org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.close:(Z)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/jboss/resteasy/plugins/providers/sse/SseEventOutputImpl;
protected void close(boolean);
descriptor: (Z)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=7, args_size=2
start local 0 start local 1 0: aload 0
getfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.closed:Z
ifeq 2
1: return
2: StackMap locals:
StackMap stack:
aload 0
getfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.lock:Ljava/lang/Object;
dup
astore 2
monitorenter
3: aload 0
iconst_1
putfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.closed:Z
4: iload 1
ifeq 16
aload 0
getfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.responseFlushed:Z
ifeq 16
5: aconst_null
astore 3
aconst_null
astore 4
6: aload 0
getfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.contextDataMap:Ljava/util/Map;
invokestatic org.jboss.resteasy.core.ResteasyContext.addCloseableContextDataLevel:(Ljava/util/Map;)Lorg/jboss/resteasy/core/ResteasyContext$CloseableContext;
astore 5
start local 5 7: aload 0
getfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.response:Lorg/jboss/resteasy/spi/HttpResponse;
invokeinterface org.jboss.resteasy.spi.HttpResponse.getAsyncOutputStream:()Lorg/jboss/resteasy/spi/AsyncOutputStream;
astore 6
start local 6 8: aload 6
invokevirtual org.jboss.resteasy.spi.AsyncOutputStream.asyncFlush:()Ljava/util/concurrent/CompletionStage;
invokeinterface java.util.concurrent.CompletionStage.toCompletableFuture:()Ljava/util/concurrent/CompletableFuture;
invokevirtual java.util.concurrent.CompletableFuture.get:()Ljava/lang/Object;
pop
end local 6 9: aload 5
ifnull 16
aload 5
invokeinterface org.jboss.resteasy.core.ResteasyContext$CloseableContext.close:()V
goto 16
StackMap locals: org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl int java.lang.Object java.lang.Throwable java.lang.Throwable org.jboss.resteasy.core.ResteasyContext$CloseableContext
StackMap stack: java.lang.Throwable
10: astore 3
aload 5
ifnull 11
aload 5
invokeinterface org.jboss.resteasy.core.ResteasyContext$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
StackMap locals: org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl int java.lang.Object
StackMap stack: java.lang.Exception
15: pop
16: StackMap locals:
StackMap stack:
aload 0
getfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.asyncContext:Lorg/jboss/resteasy/spi/ResteasyAsynchronousContext;
invokeinterface org.jboss.resteasy.spi.ResteasyAsynchronousContext.isSuspended:()Z
ifeq 30
17: aload 0
getfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.asyncContext:Lorg/jboss/resteasy/spi/ResteasyAsynchronousContext;
invokeinterface org.jboss.resteasy.spi.ResteasyAsynchronousContext.getAsyncResponse:()Lorg/jboss/resteasy/spi/ResteasyAsynchronousResponse;
astore 3
start local 3 18: aload 3
ifnull 30
19: aload 3
invokeinterface org.jboss.resteasy.spi.ResteasyAsynchronousResponse.complete:()V
20: goto 30
StackMap locals: org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl int java.lang.Object org.jboss.resteasy.spi.ResteasyAsynchronousResponse
StackMap stack: java.lang.RuntimeException
21: astore 4
start local 4 22: aload 4
astore 5
start local 5 23: goto 25
24: StackMap locals: java.lang.RuntimeException java.lang.Throwable
StackMap stack:
aload 5
invokevirtual java.lang.Throwable.getCause:()Ljava/lang/Throwable;
astore 5
25: StackMap locals:
StackMap stack:
aload 5
invokevirtual java.lang.Throwable.getCause:()Ljava/lang/Throwable;
ifnull 26
aload 5
invokevirtual java.lang.Throwable.getCause:()Ljava/lang/Throwable;
aload 5
if_acmpne 24
26: StackMap locals:
StackMap stack:
aload 5
instanceof java.io.IOException
ifne 30
27: getstatic org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.LOG:Lorg/jboss/logging/Logger;
aload 5
invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
invokevirtual org.jboss.logging.Logger.debug:(Ljava/lang/Object;)V
28: aload 2
monitorexit
29: return
end local 5 end local 4 end local 3 30: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.clearContextData:()V
31: aload 2
monitorexit
32: goto 35
StackMap locals:
StackMap stack: java.lang.Throwable
33: aload 2
monitorexit
34: athrow
35: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 36 0 this Lorg/jboss/resteasy/plugins/providers/sse/SseEventOutputImpl;
0 36 1 flushBeforeClose Z
7 11 5 c Lorg/jboss/resteasy/core/ResteasyContext$CloseableContext;
8 9 6 aos Lorg/jboss/resteasy/spi/AsyncOutputStream;
18 30 3 asyncResponse Lorg/jboss/resteasy/spi/ResteasyAsynchronousResponse;
22 30 4 x Ljava/lang/RuntimeException;
23 30 5 cause Ljava/lang/Throwable;
Exception table:
from to target type
7 9 10 any
6 12 12 any
5 15 15 Class java.io.IOException
5 15 15 Class java.lang.InterruptedException
5 15 15 Class java.util.concurrent.ExecutionException
19 20 21 Class java.lang.RuntimeException
3 29 33 any
30 32 33 any
33 34 33 any
MethodParameters:
Name Flags
flushBeforeClose
public void clearContextData();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=1
start local 0 0: iconst_0
invokestatic org.jboss.resteasy.core.ResteasyContext.getContextDataMap:(Z)Ljava/util/Map;
astore 1
start local 1 1: aload 1
ifnull 2
aload 1
ldc Lorg/jboss/resteasy/plugins/server/Cleanables;
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.jboss.resteasy.plugins.server.Cleanables
goto 3
StackMap locals: java.util.Map
StackMap stack:
2: aconst_null
StackMap locals:
StackMap stack: org.jboss.resteasy.plugins.server.Cleanables
3: astore 2
start local 2 4: aload 2
ifnull 12
5: aload 2
invokevirtual org.jboss.resteasy.plugins.server.Cleanables.getCleanables:()Ljava/util/HashSet;
invokevirtual java.util.HashSet.iterator:()Ljava/util/Iterator;
astore 3
start local 3 6: goto 10
7: StackMap locals: org.jboss.resteasy.plugins.server.Cleanables java.util.Iterator
StackMap stack:
aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.jboss.resteasy.plugins.server.Cleanable
invokeinterface org.jboss.resteasy.plugins.server.Cleanable.clean:()V
8: goto 10
9: StackMap locals:
StackMap stack: java.lang.Exception
pop
10: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 7
end local 3 11: invokestatic org.jboss.resteasy.core.ResteasyContext.clearContextData:()V
12: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lorg/jboss/resteasy/plugins/providers/sse/SseEventOutputImpl;
1 13 1 map Ljava/util/Map<Ljava/lang/Class<*>;Ljava/lang/Object;>;
4 13 2 cleanables Lorg/jboss/resteasy/plugins/server/Cleanables;
6 11 3 it Ljava/util/Iterator<Lorg/jboss/resteasy/plugins/server/Cleanable;>;
Exception table:
from to target type
7 8 9 Class java.lang.Exception
protected void flushResponseToClient();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
iconst_0
invokevirtual org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.internalFlushResponseToClient:(Z)Ljava/util/concurrent/CompletionStage;
pop
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/jboss/resteasy/plugins/providers/sse/SseEventOutputImpl;
private java.util.concurrent.CompletionStage<java.lang.Void> internalFlushResponseToClient(boolean);
descriptor: (Z)Ljava/util/concurrent/CompletionStage;
flags: (0x0002) ACC_PRIVATE
Code:
stack=7, locals=11, args_size=2
start local 0 start local 1 0: aload 0
getfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.responseFlushed:Z
ifeq 2
1: aconst_null
invokestatic java.util.concurrent.CompletableFuture.completedFuture:(Ljava/lang/Object;)Ljava/util/concurrent/CompletableFuture;
areturn
2: StackMap locals:
StackMap stack:
aload 0
getfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.lock:Ljava/lang/Object;
dup
astore 2
monitorenter
3: aload 0
getfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.responseFlushed:Z
ifne 48
4: aconst_null
astore 3
start local 3 5: aload 0
getfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.closed:Z
ifeq 8
6: 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
7: goto 31
8: StackMap locals: java.lang.Object org.jboss.resteasy.specimpl.BuiltResponse
StackMap stack:
aload 0
getfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.request:Lorg/jboss/resteasy/spi/HttpRequest;
ldc Lorg/jboss/resteasy/core/ResourceMethodInvoker;
invokevirtual java.lang.Class.getName:()Ljava/lang/String;
invokeinterface org.jboss.resteasy.spi.HttpRequest.getAttribute:(Ljava/lang/String;)Ljava/lang/Object;
checkcast org.jboss.resteasy.core.ResourceMethodInvoker
astore 4
start local 4 9: aload 4
invokevirtual org.jboss.resteasy.core.ResourceMethodInvoker.getProduces:()[Ljavax/ws/rs/core/MediaType;
astore 5
start local 5 10: aload 5
ifnull 20
aload 0
aload 5
invokevirtual org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.getSseEventType:([Ljavax/ws/rs/core/MediaType;)Ljavax/ws/rs/core/MediaType;
ifnull 20
11: aload 4
invokevirtual org.jboss.resteasy.core.ResourceMethodInvoker.getMethodAnnotations:()[Ljava/lang/annotation/Annotation;
ldc Lorg/jboss/resteasy/annotations/SseElementType;
invokestatic org.jboss.resteasy.spi.util.FindAnnotation.findAnnotation:([Ljava/lang/annotation/Annotation;Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.jboss.resteasy.annotations.SseElementType
astore 6
start local 6 12: aload 6
ifnull 18
13: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
astore 7
start local 7 14: aload 7
ldc "element-type"
aload 6
invokeinterface org.jboss.resteasy.annotations.SseElementType.value:()Ljava/lang/String;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
15: new javax.ws.rs.core.MediaType
dup
getstatic javax.ws.rs.core.MediaType.SERVER_SENT_EVENTS_TYPE:Ljavax/ws/rs/core/MediaType;
invokevirtual javax.ws.rs.core.MediaType.getType:()Ljava/lang/String;
getstatic javax.ws.rs.core.MediaType.SERVER_SENT_EVENTS_TYPE:Ljavax/ws/rs/core/MediaType;
invokevirtual javax.ws.rs.core.MediaType.getSubtype:()Ljava/lang/String;
aload 7
invokespecial javax.ws.rs.core.MediaType.<init>:(Ljava/lang/String;Ljava/lang/String;Ljava/util/Map;)V
astore 8
start local 8 16: invokestatic javax.ws.rs.core.Response.ok:()Ljavax/ws/rs/core/Response$ResponseBuilder;
aload 8
invokevirtual javax.ws.rs.core.Response$ResponseBuilder.type:(Ljavax/ws/rs/core/MediaType;)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
end local 8 end local 7 17: goto 31
18: StackMap locals: org.jboss.resteasy.core.ResourceMethodInvoker javax.ws.rs.core.MediaType[] org.jboss.resteasy.annotations.SseElementType
StackMap stack:
invokestatic javax.ws.rs.core.Response.ok:()Ljavax/ws/rs/core/Response$ResponseBuilder;
aload 0
aload 5
invokevirtual org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.getSseEventType:([Ljavax/ws/rs/core/MediaType;)Ljavax/ws/rs/core/MediaType;
invokevirtual javax.ws.rs.core.Response$ResponseBuilder.type:(Ljavax/ws/rs/core/MediaType;)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
end local 6 19: goto 31
20: StackMap locals:
StackMap stack:
aload 4
invokevirtual org.jboss.resteasy.core.ResourceMethodInvoker.getMethodAnnotations:()[Ljava/lang/annotation/Annotation;
ldc Lorg/jboss/resteasy/annotations/Stream;
invokestatic org.jboss.resteasy.spi.util.FindAnnotation.findAnnotation:([Ljava/lang/annotation/Annotation;Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.jboss.resteasy.annotations.Stream
astore 6
start local 6 21: aload 6
ifnull 30
22: ldc ""
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 3
23: aload 3
aload 0
getfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.request:Lorg/jboss/resteasy/spi/HttpRequest;
aload 0
getfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.response:Lorg/jboss/resteasy/spi/HttpResponse;
aload 0
getfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.providerFactory:Lorg/jboss/resteasy/spi/ResteasyProviderFactory;
aload 4
invokestatic org.jboss.resteasy.core.ServerResponseWriter.getResponseMediaType:(Lorg/jboss/resteasy/specimpl/BuiltResponse;Lorg/jboss/resteasy/spi/HttpRequest;Lorg/jboss/resteasy/spi/HttpResponse;Lorg/jboss/resteasy/spi/ResteasyProviderFactory;Lorg/jboss/resteasy/core/ResourceMethodInvoker;)Ljavax/ws/rs/core/MediaType;
astore 7
start local 7 24: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
astore 8
start local 8 25: aload 8
ldc "element-type"
aload 7
invokevirtual javax.ws.rs.core.MediaType.toString:()Ljava/lang/String;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
26: aload 0
aload 4
invokevirtual org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.getStreamType:(Lorg/jboss/resteasy/core/ResourceMethodInvoker;)[Ljava/lang/String;
astore 9
start local 9 27: new javax.ws.rs.core.MediaType
dup
aload 9
iconst_0
aaload
aload 9
iconst_1
aaload
aload 8
invokespecial javax.ws.rs.core.MediaType.<init>:(Ljava/lang/String;Ljava/lang/String;Ljava/util/Map;)V
astore 10
start local 10 28: invokestatic javax.ws.rs.core.Response.ok:()Ljavax/ws/rs/core/Response$ResponseBuilder;
aload 10
invokevirtual javax.ws.rs.core.Response$ResponseBuilder.type:(Ljavax/ws/rs/core/MediaType;)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
end local 10 end local 9 end local 8 end local 7 29: goto 31
30: StackMap locals: org.jboss.resteasy.annotations.Stream
StackMap stack:
new java.lang.RuntimeException
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.expectedStreamOrSseMediaType:()Ljava/lang/String;
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;)V
athrow
end local 6 end local 5 end local 4 31: StackMap locals:
StackMap stack:
new java.util.concurrent.CompletableFuture
dup
invokespecial java.util.concurrent.CompletableFuture.<init>:()V
astore 4
start local 4 32: aload 3
aload 0
getfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.request:Lorg/jboss/resteasy/spi/HttpRequest;
aload 0
getfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.response:Lorg/jboss/resteasy/spi/HttpResponse;
33: aload 0
getfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.providerFactory:Lorg/jboss/resteasy/spi/ResteasyProviderFactory;
aload 0
aload 4
iload 1
invokedynamic accept(Lorg/jboss/resteasy/plugins/providers/sse/SseEventOutputImpl;Ljava/util/concurrent/CompletableFuture;Z)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/plugins/providers/sse/SseEventOutputImpl.lambda$0(Ljava/util/concurrent/CompletableFuture;ZLjava/lang/Throwable;)V (7)
(Ljava/lang/Throwable;)V
34: iconst_1
35: 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
36: aload 4
37: aload 2
monitorexit
38: areturn
end local 4 39: StackMap locals:
StackMap stack: java.io.IOException
astore 4
start local 4 40: aload 0
iconst_0
invokevirtual org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.close:(Z)V
41: new java.util.concurrent.CompletableFuture
dup
invokespecial java.util.concurrent.CompletableFuture.<init>:()V
astore 5
start local 5 42: iload 1
ifeq 45
43: aload 5
aload 4
invokevirtual java.util.concurrent.CompletableFuture.completeExceptionally:(Ljava/lang/Throwable;)Z
pop
44: goto 46
45: StackMap locals: java.io.IOException java.util.concurrent.CompletableFuture
StackMap stack:
aload 5
new javax.ws.rs.ProcessingException
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.failedToCreateSseEventOutput:()Ljava/lang/String;
aload 4
invokespecial javax.ws.rs.ProcessingException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
invokevirtual java.util.concurrent.CompletableFuture.completeExceptionally:(Ljava/lang/Throwable;)Z
pop
46: StackMap locals:
StackMap stack:
aload 5
aload 2
monitorexit
47: areturn
end local 5 end local 4 end local 3 48: StackMap locals:
StackMap stack:
aload 2
monitorexit
49: goto 52
StackMap locals:
StackMap stack: java.lang.Throwable
50: aload 2
monitorexit
51: athrow
52: StackMap locals:
StackMap stack:
aconst_null
invokestatic java.util.concurrent.CompletableFuture.completedFuture:(Ljava/lang/Object;)Ljava/util/concurrent/CompletableFuture;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 53 0 this Lorg/jboss/resteasy/plugins/providers/sse/SseEventOutputImpl;
0 53 1 throwIOException Z
5 48 3 jaxrsResponse Lorg/jboss/resteasy/specimpl/BuiltResponse;
9 31 4 method Lorg/jboss/resteasy/core/ResourceMethodInvoker;
10 31 5 mediaTypes [Ljavax/ws/rs/core/MediaType;
12 19 6 sseElementType Lorg/jboss/resteasy/annotations/SseElementType;
14 17 7 parameterMap Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
16 17 8 mediaType Ljavax/ws/rs/core/MediaType;
21 31 6 stream Lorg/jboss/resteasy/annotations/Stream;
24 29 7 elementType Ljavax/ws/rs/core/MediaType;
25 29 8 parameterMap Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
27 29 9 streamType [Ljava/lang/String;
28 29 10 mediaType Ljavax/ws/rs/core/MediaType;
32 39 4 ret Ljava/util/concurrent/CompletableFuture<Ljava/lang/Void;>;
40 48 4 e Ljava/io/IOException;
42 48 5 ret Ljava/util/concurrent/CompletableFuture<Ljava/lang/Void;>;
Exception table:
from to target type
31 37 39 Class java.io.IOException
3 38 50 any
39 47 50 any
48 49 50 any
50 51 50 any
Signature: (Z)Ljava/util/concurrent/CompletionStage<Ljava/lang/Void;>;
MethodParameters:
Name Flags
throwIOException
public boolean isClosed();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.closed:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/jboss/resteasy/plugins/providers/sse/SseEventOutputImpl;
public java.util.concurrent.CompletionStage<?> send(javax.ws.rs.sse.OutboundSseEvent);
descriptor: (Ljavax/ws/rs/sse/OutboundSseEvent;)Ljava/util/concurrent/CompletionStage;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.lock:Ljava/lang/Object;
dup
astore 2
monitorenter
1: aload 0
getfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.closed:Z
ifeq 3
2: 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.sseEventSinkIsClosed:()Ljava/lang/String;
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
3: StackMap locals: java.lang.Object
StackMap stack:
aload 0
iconst_1
invokevirtual org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.internalFlushResponseToClient:(Z)Ljava/util/concurrent/CompletionStage;
4: aload 0
aload 1
invokedynamic apply(Lorg/jboss/resteasy/plugins/providers/sse/SseEventOutputImpl;Ljavax/ws/rs/sse/OutboundSseEvent;)Ljava/util/function/Function;
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;)Ljava/lang/Object;
org/jboss/resteasy/plugins/providers/sse/SseEventOutputImpl.lambda$4(Ljavax/ws/rs/sse/OutboundSseEvent;Ljava/lang/Void;)Ljava/util/concurrent/CompletionStage; (7)
(Ljava/lang/Void;)Ljava/util/concurrent/CompletionStage;
invokeinterface java.util.concurrent.CompletionStage.thenCompose:(Ljava/util/function/Function;)Ljava/util/concurrent/CompletionStage;
5: aload 2
monitorexit
6: areturn
7: StackMap locals:
StackMap stack: java.lang.Throwable
aload 2
monitorexit
8: athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lorg/jboss/resteasy/plugins/providers/sse/SseEventOutputImpl;
0 9 1 event Ljavax/ws/rs/sse/OutboundSseEvent;
Exception table:
from to target type
1 6 7 any
7 8 7 any
Signature: (Ljavax/ws/rs/sse/OutboundSseEvent;)Ljava/util/concurrent/CompletionStage<*>;
MethodParameters:
Name Flags
event
protected java.util.concurrent.CompletionStage<java.lang.Void> writeEvent(javax.ws.rs.sse.OutboundSseEvent);
descriptor: (Ljavax/ws/rs/sse/OutboundSseEvent;)Ljava/util/concurrent/CompletionStage;
flags: (0x0004) ACC_PROTECTED
Code:
stack=8, locals=12, args_size=2
start local 0 start local 1 0: aload 0
getfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.lock:Ljava/lang/Object;
dup
astore 2
monitorenter
1: aconst_null
astore 3
aconst_null
astore 4
2: aload 0
getfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.contextDataMap:Ljava/util/Map;
invokestatic org.jboss.resteasy.core.ResteasyContext.addCloseableContextDataLevel:(Ljava/util/Map;)Lorg/jboss/resteasy/core/ResteasyContext$CloseableContext;
astore 5
start local 5 3: aload 1
ifnull 37
4: new java.io.ByteArrayOutputStream
dup
invokespecial java.io.ByteArrayOutputStream.<init>:()V
astore 6
start local 6 5: aload 1
invokeinterface javax.ws.rs.sse.OutboundSseEvent.getMediaType:()Ljavax/ws/rs/core/MediaType;
astore 7
start local 7 6: aload 1
instanceof org.jboss.resteasy.plugins.providers.sse.OutboundSseEventImpl
ifeq 7
aload 1
checkcast org.jboss.resteasy.plugins.providers.sse.OutboundSseEventImpl
invokevirtual org.jboss.resteasy.plugins.providers.sse.OutboundSseEventImpl.isMediaTypeSet:()Z
goto 8
StackMap locals: org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl javax.ws.rs.sse.OutboundSseEvent java.lang.Object java.lang.Throwable java.lang.Throwable org.jboss.resteasy.core.ResteasyContext$CloseableContext java.io.ByteArrayOutputStream javax.ws.rs.core.MediaType
StackMap stack:
7: iconst_1
StackMap locals:
StackMap stack: int
8: istore 8
start local 8 9: aload 7
ifnull 10
iload 8
ifne 25
10: StackMap locals: int
StackMap stack:
aload 0
getfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.response:Lorg/jboss/resteasy/spi/HttpResponse;
invokeinterface org.jboss.resteasy.spi.HttpResponse.getOutputHeaders:()Ljavax/ws/rs/core/MultivaluedMap;
ldc "Content-Type"
invokeinterface javax.ws.rs.core.MultivaluedMap.getFirst:(Ljava/lang/Object;)Ljava/lang/Object;
astore 9
start local 9 11: aload 9
ifnull 25
12: aload 9
instanceof javax.ws.rs.core.MediaType
ifeq 18
13: aload 9
checkcast javax.ws.rs.core.MediaType
astore 10
start local 10 14: aload 10
invokevirtual javax.ws.rs.core.MediaType.getParameters:()Ljava/util/Map;
ldc "element-type"
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.String
astore 11
start local 11 15: aload 11
ifnull 25
16: aload 11
invokestatic javax.ws.rs.core.MediaType.valueOf:(Ljava/lang/String;)Ljavax/ws/rs/core/MediaType;
astore 7
end local 11 end local 10 17: goto 25
18: StackMap locals: java.lang.Object
StackMap stack:
aload 9
instanceof java.lang.String
ifeq 24
19: aload 9
checkcast java.lang.String
invokestatic javax.ws.rs.core.MediaType.valueOf:(Ljava/lang/String;)Ljavax/ws/rs/core/MediaType;
astore 10
start local 10 20: aload 10
invokevirtual javax.ws.rs.core.MediaType.getParameters:()Ljava/util/Map;
ldc "element-type"
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.String
astore 11
start local 11 21: aload 11
ifnull 25
22: aload 11
invokestatic javax.ws.rs.core.MediaType.valueOf:(Ljava/lang/String;)Ljavax/ws/rs/core/MediaType;
astore 7
end local 11 end local 10 23: goto 25
24: StackMap locals:
StackMap stack:
new java.lang.RuntimeException
dup
getstatic org.jboss.resteasy.resteasy_jaxrs.i18n.Messages.MESSAGES:Lorg/jboss/resteasy/resteasy_jaxrs/i18n/Messages;
aload 9
invokeinterface org.jboss.resteasy.resteasy_jaxrs.i18n.Messages.expectedStringOrMediaType:(Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;)V
athrow
end local 9 25: StackMap locals:
StackMap stack:
aload 7
ifnonnull 27
26: getstatic javax.ws.rs.core.MediaType.TEXT_PLAIN_TYPE:Ljavax/ws/rs/core/MediaType;
astore 7
27: StackMap locals:
StackMap stack:
aload 1
instanceof org.jboss.resteasy.plugins.providers.sse.OutboundSseEventImpl
ifeq 29
28: aload 1
checkcast org.jboss.resteasy.plugins.providers.sse.OutboundSseEventImpl
aload 7
invokevirtual org.jboss.resteasy.plugins.providers.sse.OutboundSseEventImpl.setMediaType:(Ljavax/ws/rs/core/MediaType;)V
29: StackMap locals:
StackMap stack:
aload 0
getfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.writer:Ljavax/ws/rs/ext/MessageBodyWriter;
aload 1
aload 1
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
aconst_null
iconst_0
anewarray java.lang.annotation.Annotation
aload 7
aconst_null
aload 6
invokeinterface javax.ws.rs.ext.MessageBodyWriter.writeTo:(Ljava/lang/Object;Ljava/lang/Class;Ljava/lang/reflect/Type;[Ljava/lang/annotation/Annotation;Ljavax/ws/rs/core/MediaType;Ljavax/ws/rs/core/MultivaluedMap;Ljava/io/OutputStream;)V
30: aload 0
getfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.response:Lorg/jboss/resteasy/spi/HttpResponse;
invokeinterface org.jboss.resteasy.spi.HttpResponse.getAsyncOutputStream:()Lorg/jboss/resteasy/spi/AsyncOutputStream;
astore 9
start local 9 31: aload 9
aload 6
invokevirtual java.io.ByteArrayOutputStream.toByteArray:()[B
invokevirtual org.jboss.resteasy.spi.AsyncOutputStream.asyncWrite:([B)Ljava/util/concurrent/CompletionStage;
32: aload 9
invokedynamic apply(Lorg/jboss/resteasy/spi/AsyncOutputStream;)Ljava/util/function/Function;
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;)Ljava/lang/Object;
org/jboss/resteasy/plugins/providers/sse/SseEventOutputImpl.lambda$5(Lorg/jboss/resteasy/spi/AsyncOutputStream;Ljava/lang/Void;)Ljava/util/concurrent/CompletionStage; (6)
(Ljava/lang/Void;)Ljava/util/concurrent/CompletionStage;
invokeinterface java.util.concurrent.CompletionStage.thenCompose:(Ljava/util/function/Function;)Ljava/util/concurrent/CompletionStage;
33: aload 0
aload 1
invokedynamic apply(Lorg/jboss/resteasy/plugins/providers/sse/SseEventOutputImpl;Ljavax/ws/rs/sse/OutboundSseEvent;)Ljava/util/function/Function;
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;)Ljava/lang/Object;
org/jboss/resteasy/plugins/providers/sse/SseEventOutputImpl.lambda$6(Ljavax/ws/rs/sse/OutboundSseEvent;Ljava/lang/Throwable;)Ljava/lang/Void; (7)
(Ljava/lang/Throwable;)Ljava/lang/Void;
invokeinterface java.util.concurrent.CompletionStage.exceptionally:(Ljava/util/function/Function;)Ljava/util/concurrent/CompletionStage;
34: aload 5
ifnull 35
aload 5
invokeinterface org.jboss.resteasy.core.ResteasyContext$CloseableContext.close:()V
35: StackMap locals: org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl javax.ws.rs.sse.OutboundSseEvent java.lang.Object java.lang.Throwable java.lang.Throwable org.jboss.resteasy.core.ResteasyContext$CloseableContext java.io.ByteArrayOutputStream javax.ws.rs.core.MediaType int org.jboss.resteasy.spi.AsyncOutputStream
StackMap stack: java.util.concurrent.CompletionStage
aload 2
monitorexit
36: areturn
end local 9 end local 8 end local 7 end local 6 37: StackMap locals: org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl javax.ws.rs.sse.OutboundSseEvent java.lang.Object java.lang.Throwable java.lang.Throwable org.jboss.resteasy.core.ResteasyContext$CloseableContext
StackMap stack:
aload 5
ifnull 56
aload 5
invokeinterface org.jboss.resteasy.core.ResteasyContext$CloseableContext.close:()V
goto 56
StackMap locals:
StackMap stack: java.lang.Throwable
38: astore 3
aload 5
ifnull 39
aload 5
invokeinterface org.jboss.resteasy.core.ResteasyContext$CloseableContext.close:()V
end local 5 StackMap locals:
StackMap stack:
39: aload 3
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
40: astore 4
aload 3
ifnonnull 41
aload 4
astore 3
goto 42
StackMap locals:
StackMap stack:
41: aload 3
aload 4
if_acmpeq 42
aload 3
aload 4
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
42: aload 3
athrow
43: StackMap locals: org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl javax.ws.rs.sse.OutboundSseEvent java.lang.Object
StackMap stack: java.io.IOException
astore 3
start local 3 44: aload 0
iconst_0
invokevirtual org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.close:(Z)V
45: getstatic org.jboss.resteasy.resteasy_jaxrs.i18n.LogMessages.LOGGER:Lorg/jboss/resteasy/resteasy_jaxrs/i18n/LogMessages;
aload 1
invokevirtual java.lang.Object.toString:()Ljava/lang/String;
aload 3
invokeinterface org.jboss.resteasy.resteasy_jaxrs.i18n.LogMessages.failedToWriteSseEvent:(Ljava/lang/String;Ljava/lang/Throwable;)V
46: new java.util.concurrent.CompletableFuture
dup
invokespecial java.util.concurrent.CompletableFuture.<init>:()V
astore 4
start local 4 47: aload 4
aload 3
invokevirtual java.util.concurrent.CompletableFuture.completeExceptionally:(Ljava/lang/Throwable;)Z
pop
48: aload 4
aload 2
monitorexit
49: areturn
end local 4 end local 3 50: StackMap locals:
StackMap stack: java.lang.Exception
astore 3
start local 3 51: getstatic org.jboss.resteasy.resteasy_jaxrs.i18n.LogMessages.LOGGER:Lorg/jboss/resteasy/resteasy_jaxrs/i18n/LogMessages;
aload 1
invokevirtual java.lang.Object.toString:()Ljava/lang/String;
aload 3
invokeinterface org.jboss.resteasy.resteasy_jaxrs.i18n.LogMessages.failedToWriteSseEvent:(Ljava/lang/String;Ljava/lang/Throwable;)V
52: new java.util.concurrent.CompletableFuture
dup
invokespecial java.util.concurrent.CompletableFuture.<init>:()V
astore 4
start local 4 53: aload 4
new javax.ws.rs.ProcessingException
dup
aload 3
invokespecial javax.ws.rs.ProcessingException.<init>:(Ljava/lang/Throwable;)V
invokevirtual java.util.concurrent.CompletableFuture.completeExceptionally:(Ljava/lang/Throwable;)Z
pop
54: aload 4
aload 2
monitorexit
55: areturn
end local 4 end local 3 56: StackMap locals:
StackMap stack:
aload 2
monitorexit
57: goto 60
StackMap locals:
StackMap stack: java.lang.Throwable
58: aload 2
monitorexit
59: athrow
60: StackMap locals:
StackMap stack:
aconst_null
invokestatic java.util.concurrent.CompletableFuture.completedFuture:(Ljava/lang/Object;)Ljava/util/concurrent/CompletableFuture;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 61 0 this Lorg/jboss/resteasy/plugins/providers/sse/SseEventOutputImpl;
0 61 1 event Ljavax/ws/rs/sse/OutboundSseEvent;
3 39 5 c Lorg/jboss/resteasy/core/ResteasyContext$CloseableContext;
5 37 6 bout Ljava/io/ByteArrayOutputStream;
6 37 7 mediaType Ljavax/ws/rs/core/MediaType;
9 37 8 mediaTypeSet Z
11 25 9 o Ljava/lang/Object;
14 17 10 mt Ljavax/ws/rs/core/MediaType;
15 17 11 s Ljava/lang/String;
20 23 10 mt Ljavax/ws/rs/core/MediaType;
21 23 11 s Ljava/lang/String;
31 37 9 aos Lorg/jboss/resteasy/spi/AsyncOutputStream;
44 50 3 e Ljava/io/IOException;
47 50 4 ret Ljava/util/concurrent/CompletableFuture<Ljava/lang/Void;>;
51 56 3 e Ljava/lang/Exception;
53 56 4 ret Ljava/util/concurrent/CompletableFuture<Ljava/lang/Void;>;
Exception table:
from to target type
3 34 38 any
2 35 40 any
37 40 40 any
1 35 43 Class java.io.IOException
37 43 43 Class java.io.IOException
1 35 50 Class java.lang.Exception
37 43 50 Class java.lang.Exception
1 36 58 any
37 49 58 any
50 55 58 any
56 57 58 any
58 59 58 any
Signature: (Ljavax/ws/rs/sse/OutboundSseEvent;)Ljava/util/concurrent/CompletionStage<Ljava/lang/Void;>;
MethodParameters:
Name Flags
event
private java.lang.String[] getStreamType(org.jboss.resteasy.core.ResourceMethodInvoker);
descriptor: (Lorg/jboss/resteasy/core/ResourceMethodInvoker;)[Ljava/lang/String;
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=4, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual org.jboss.resteasy.core.ResourceMethodInvoker.getMethodAnnotations:()[Ljava/lang/annotation/Annotation;
ldc Lorg/jboss/resteasy/annotations/Stream;
invokestatic org.jboss.resteasy.spi.util.FindAnnotation.findAnnotation:([Ljava/lang/annotation/Annotation;Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.jboss.resteasy.annotations.Stream
astore 2
start local 2 1: aload 2
ifnull 2
aload 2
invokeinterface org.jboss.resteasy.annotations.Stream.value:()Lorg/jboss/resteasy/annotations/Stream$MODE;
goto 3
StackMap locals: org.jboss.resteasy.annotations.Stream
StackMap stack:
2: aconst_null
StackMap locals:
StackMap stack: org.jboss.resteasy.annotations.Stream$MODE
3: astore 3
start local 3 4: aload 3
ifnonnull 6
5: iconst_2
anewarray java.lang.String
dup
iconst_0
ldc "text"
aastore
dup
iconst_1
ldc "event-stream"
aastore
areturn
6: StackMap locals: org.jboss.resteasy.annotations.Stream$MODE
StackMap stack:
getstatic org.jboss.resteasy.annotations.Stream$MODE.GENERAL:Lorg/jboss/resteasy/annotations/Stream$MODE;
aload 3
invokevirtual org.jboss.resteasy.annotations.Stream$MODE.equals:(Ljava/lang/Object;)Z
ifeq 8
7: iconst_2
anewarray java.lang.String
dup
iconst_0
ldc "application"
aastore
dup
iconst_1
ldc "x-stream-general"
aastore
areturn
8: StackMap locals:
StackMap stack:
getstatic org.jboss.resteasy.annotations.Stream$MODE.RAW:Lorg/jboss/resteasy/annotations/Stream$MODE;
aload 3
invokevirtual org.jboss.resteasy.annotations.Stream$MODE.equals:(Ljava/lang/Object;)Z
ifeq 10
9: iconst_2
anewarray java.lang.String
dup
iconst_0
ldc "application"
aastore
dup
iconst_1
ldc "x-stream-raw"
aastore
areturn
10: StackMap locals:
StackMap stack:
new java.lang.RuntimeException
dup
getstatic org.jboss.resteasy.resteasy_jaxrs.i18n.Messages.MESSAGES:Lorg/jboss/resteasy/resteasy_jaxrs/i18n/Messages;
aload 3
invokeinterface org.jboss.resteasy.resteasy_jaxrs.i18n.Messages.expectedStreamModeGeneralOrRaw:(Lorg/jboss/resteasy/annotations/Stream$MODE;)Ljava/lang/String;
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;)V
athrow
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lorg/jboss/resteasy/plugins/providers/sse/SseEventOutputImpl;
0 11 1 method Lorg/jboss/resteasy/core/ResourceMethodInvoker;
1 11 2 stream Lorg/jboss/resteasy/annotations/Stream;
4 11 3 mode Lorg/jboss/resteasy/annotations/Stream$MODE;
MethodParameters:
Name Flags
method
public boolean equals(java.lang.Object);
descriptor: (Ljava/lang/Object;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
if_acmpne 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/jboss/resteasy/plugins/providers/sse/SseEventOutputImpl;
0 2 1 o Ljava/lang/Object;
MethodParameters:
Name Flags
o
public int hashCode();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokespecial javax.ws.rs.core.GenericType.hashCode:()I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/jboss/resteasy/plugins/providers/sse/SseEventOutputImpl;
private javax.ws.rs.core.MediaType getSseEventType(javax.ws.rs.core.MediaType[]);
descriptor: ([Ljavax/ws/rs/core/MediaType;)Ljavax/ws/rs/core/MediaType;
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=6, args_size=2
start local 0 start local 1 0: aload 1
dup
astore 5
arraylength
istore 4
iconst_0
istore 3
goto 6
StackMap locals: org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl javax.ws.rs.core.MediaType[] top int int javax.ws.rs.core.MediaType[]
StackMap stack:
1: aload 5
iload 3
aaload
astore 2
start local 2 2: aload 2
invokevirtual javax.ws.rs.core.MediaType.getType:()Ljava/lang/String;
getstatic javax.ws.rs.core.MediaType.SERVER_SENT_EVENTS_TYPE:Ljavax/ws/rs/core/MediaType;
invokevirtual javax.ws.rs.core.MediaType.getType:()Ljava/lang/String;
invokevirtual java.lang.String.equalsIgnoreCase:(Ljava/lang/String;)Z
ifeq 5
3: aload 2
invokevirtual javax.ws.rs.core.MediaType.getSubtype:()Ljava/lang/String;
getstatic javax.ws.rs.core.MediaType.SERVER_SENT_EVENTS_TYPE:Ljavax/ws/rs/core/MediaType;
invokevirtual javax.ws.rs.core.MediaType.getSubtype:()Ljava/lang/String;
invokevirtual java.lang.String.equalsIgnoreCase:(Ljava/lang/String;)Z
ifeq 5
4: aload 2
areturn
end local 2 5: StackMap locals:
StackMap stack:
iinc 3 1
StackMap locals:
StackMap stack:
6: iload 3
iload 4
if_icmplt 1
7: aconst_null
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lorg/jboss/resteasy/plugins/providers/sse/SseEventOutputImpl;
0 8 1 mediaTypes [Ljavax/ws/rs/core/MediaType;
2 5 2 type Ljavax/ws/rs/core/MediaType;
MethodParameters:
Name Flags
mediaTypes
private void lambda$0(java.util.concurrent.CompletableFuture, boolean, java.lang.Throwable);
descriptor: (Ljava/util/concurrent/CompletableFuture;ZLjava/lang/Throwable;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=4, locals=6, args_size=4
start local 0 start local 3 0: aload 0
getfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.response:Lorg/jboss/resteasy/spi/HttpResponse;
invokeinterface org.jboss.resteasy.spi.HttpResponse.getAsyncOutputStream:()Lorg/jboss/resteasy/spi/AsyncOutputStream;
astore 4
start local 4 1: goto 6
end local 4 StackMap locals:
StackMap stack: java.io.IOException
2: astore 5
start local 5 3: aload 0
iconst_0
invokevirtual org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.close:(Z)V
4: aload 1
aload 5
invokevirtual java.util.concurrent.CompletableFuture.completeExceptionally:(Ljava/lang/Throwable;)Z
pop
5: return
end local 5 start local 4 6: StackMap locals: org.jboss.resteasy.spi.AsyncOutputStream
StackMap stack:
aload 4
getstatic org.jboss.resteasy.plugins.providers.sse.SseConstants.DOUBLE_EOL:[B
invokevirtual org.jboss.resteasy.spi.AsyncOutputStream.asyncWrite:([B)Ljava/util/concurrent/CompletionStage;
7: aload 4
invokedynamic apply(Lorg/jboss/resteasy/spi/AsyncOutputStream;)Ljava/util/function/Function;
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;)Ljava/lang/Object;
org/jboss/resteasy/plugins/providers/sse/SseEventOutputImpl.lambda$1(Lorg/jboss/resteasy/spi/AsyncOutputStream;Ljava/lang/Void;)Ljava/util/concurrent/CompletionStage; (6)
(Ljava/lang/Void;)Ljava/util/concurrent/CompletionStage;
invokeinterface java.util.concurrent.CompletionStage.thenCompose:(Ljava/util/function/Function;)Ljava/util/concurrent/CompletionStage;
8: astore 5
start local 5 9: aload 0
iconst_1
putfield org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.responseFlushed:Z
10: aload 5
aload 1
invokedynamic accept(Ljava/util/concurrent/CompletableFuture;)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/plugins/providers/sse/SseEventOutputImpl.lambda$2(Ljava/util/concurrent/CompletableFuture;Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface java.util.concurrent.CompletionStage.thenAccept:(Ljava/util/function/Consumer;)Ljava/util/concurrent/CompletionStage;
11: aload 0
iload 2
aload 1
invokedynamic apply(Lorg/jboss/resteasy/plugins/providers/sse/SseEventOutputImpl;ZLjava/util/concurrent/CompletableFuture;)Ljava/util/function/Function;
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;)Ljava/lang/Object;
org/jboss/resteasy/plugins/providers/sse/SseEventOutputImpl.lambda$3(ZLjava/util/concurrent/CompletableFuture;Ljava/lang/Throwable;)Ljava/lang/Void; (7)
(Ljava/lang/Throwable;)Ljava/lang/Void;
invokeinterface java.util.concurrent.CompletionStage.exceptionally:(Ljava/util/function/Function;)Ljava/util/concurrent/CompletionStage;
pop
end local 5 end local 4 12: return
end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lorg/jboss/resteasy/plugins/providers/sse/SseEventOutputImpl;
0 13 3 t Ljava/lang/Throwable;
1 2 4 aos Lorg/jboss/resteasy/spi/AsyncOutputStream;
6 12 4 aos Lorg/jboss/resteasy/spi/AsyncOutputStream;
3 6 5 x Ljava/io/IOException;
9 12 5 a Ljava/util/concurrent/CompletionStage<Ljava/lang/Void;>;
Exception table:
from to target type
0 1 2 Class java.io.IOException
private java.util.concurrent.CompletionStage lambda$4(javax.ws.rs.sse.OutboundSseEvent, java.lang.Void);
descriptor: (Ljavax/ws/rs/sse/OutboundSseEvent;Ljava/lang/Void;)Ljava/util/concurrent/CompletionStage;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 2 0: aload 0
aload 1
invokevirtual org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.writeEvent:(Ljavax/ws/rs/sse/OutboundSseEvent;)Ljava/util/concurrent/CompletionStage;
areturn
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/jboss/resteasy/plugins/providers/sse/SseEventOutputImpl;
0 1 2 v Ljava/lang/Void;
private static java.util.concurrent.CompletionStage lambda$5(org.jboss.resteasy.spi.AsyncOutputStream, java.lang.Void);
descriptor: (Lorg/jboss/resteasy/spi/AsyncOutputStream;Ljava/lang/Void;)Ljava/util/concurrent/CompletionStage;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=2, args_size=2
start local 1 0: aload 0
invokevirtual org.jboss.resteasy.spi.AsyncOutputStream.asyncFlush:()Ljava/util/concurrent/CompletionStage;
areturn
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 v Ljava/lang/Void;
private java.lang.Void lambda$6(javax.ws.rs.sse.OutboundSseEvent, java.lang.Throwable);
descriptor: (Ljavax/ws/rs/sse/OutboundSseEvent;Ljava/lang/Throwable;)Ljava/lang/Void;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 2 0: aload 2
instanceof java.util.concurrent.CompletionException
ifeq 2
1: aload 2
invokevirtual java.lang.Throwable.getCause:()Ljava/lang/Throwable;
astore 2
2: StackMap locals:
StackMap stack:
aload 2
instanceof java.io.IOException
ifeq 4
3: aload 0
iconst_0
invokevirtual org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.close:(Z)V
4: StackMap locals:
StackMap stack:
getstatic org.jboss.resteasy.resteasy_jaxrs.i18n.LogMessages.LOGGER:Lorg/jboss/resteasy/resteasy_jaxrs/i18n/LogMessages;
aload 1
invokevirtual java.lang.Object.toString:()Ljava/lang/String;
aload 2
invokeinterface org.jboss.resteasy.resteasy_jaxrs.i18n.LogMessages.failedToWriteSseEvent:(Ljava/lang/String;Ljava/lang/Throwable;)V
5: aload 2
invokestatic org.jboss.resteasy.core.SynchronousDispatcher.rethrow:(Ljava/lang/Throwable;)V
6: aconst_null
areturn
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/jboss/resteasy/plugins/providers/sse/SseEventOutputImpl;
0 7 2 e Ljava/lang/Throwable;
private static java.util.concurrent.CompletionStage lambda$1(org.jboss.resteasy.spi.AsyncOutputStream, java.lang.Void);
descriptor: (Lorg/jboss/resteasy/spi/AsyncOutputStream;Ljava/lang/Void;)Ljava/util/concurrent/CompletionStage;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=2, args_size=2
start local 1 0: aload 0
invokevirtual org.jboss.resteasy.spi.AsyncOutputStream.asyncFlush:()Ljava/util/concurrent/CompletionStage;
areturn
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 v Ljava/lang/Void;
private static void lambda$2(java.util.concurrent.CompletableFuture, java.lang.Void);
descriptor: (Ljava/util/concurrent/CompletableFuture;Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 0
aconst_null
invokevirtual java.util.concurrent.CompletableFuture.complete:(Ljava/lang/Object;)Z
pop
1: return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 2 1 v Ljava/lang/Void;
private java.lang.Void lambda$3(boolean, java.util.concurrent.CompletableFuture, java.lang.Throwable);
descriptor: (ZLjava/util/concurrent/CompletableFuture;Ljava/lang/Throwable;)Ljava/lang/Void;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 3 0: aload 3
instanceof java.util.concurrent.CompletionException
ifeq 2
1: aload 3
invokevirtual java.lang.Throwable.getCause:()Ljava/lang/Throwable;
astore 3
2: StackMap locals:
StackMap stack:
aload 3
instanceof java.io.IOException
ifeq 4
3: aload 0
iconst_0
invokevirtual org.jboss.resteasy.plugins.providers.sse.SseEventOutputImpl.close:(Z)V
4: StackMap locals:
StackMap stack:
iload 1
ifeq 6
5: aload 2
aload 3
invokevirtual java.util.concurrent.CompletableFuture.completeExceptionally:(Ljava/lang/Throwable;)Z
pop
goto 7
6: StackMap locals:
StackMap stack:
aload 2
new javax.ws.rs.ProcessingException
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.failedToCreateSseEventOutput:()Ljava/lang/String;
aload 3
invokespecial javax.ws.rs.ProcessingException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
invokevirtual java.util.concurrent.CompletableFuture.completeExceptionally:(Ljava/lang/Throwable;)Z
pop
7: StackMap locals:
StackMap stack:
aconst_null
areturn
end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lorg/jboss/resteasy/plugins/providers/sse/SseEventOutputImpl;
0 8 3 e Ljava/lang/Throwable;
}
Signature: Ljavax/ws/rs/core/GenericType<Ljavax/ws/rs/sse/OutboundSseEvent;>;Ljavax/ws/rs/sse/SseEventSink;
SourceFile: "SseEventOutputImpl.java"
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 final MODE = org.jboss.resteasy.annotations.Stream$MODE of org.jboss.resteasy.annotations.Stream
public abstract CloseableContext = org.jboss.resteasy.core.ResteasyContext$CloseableContext of org.jboss.resteasy.core.ResteasyContext