public class io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler extends java.lang.Object implements io.smallrye.graphql.client.vertx.websocket.WebSocketSubprotocolHandler
{
private static final org.jboss.logging.Logger log;
private final java.lang.Integer subscriptionInitializationTimeout;
private final io.vertx.core.http.WebSocket webSocket;
private final java.util.concurrent.CompletableFuture initialization;
private final java.util.Map uniOperations;
private final java.util.Map multiOperations;
private final java.lang.Runnable onClose;
private final io.smallrye.graphql.client.vertx.websocket.opid.OperationIDGenerator operationIdGenerator;
private final java.util.Map initPayload;
public void <init>(io.vertx.core.http.WebSocket, java.lang.Integer, java.util.Map, java.lang.Runnable)
{
java.util.concurrent.ConcurrentHashMap v, v;
java.util.HashMap v;
java.util.concurrent.CompletableFuture v;
io.vertx.core.http.WebSocket v;
java.lang.Integer v;
java.lang.Runnable v;
io.smallrye.mutiny.Uni v;
io.smallrye.graphql.client.vertx.websocket.opid.IncrementingNumberOperationIDGenerator v;
java.util.Map v, v;
io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler v;
v := @this: io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler;
v := @parameter: io.vertx.core.http.WebSocket;
v := @parameter: java.lang.Integer;
v := @parameter: java.util.Map;
v := @parameter: java.lang.Runnable;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: java.util.Map initPayload> = v;
if v == null goto label;
v = v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: java.util.Map initPayload>;
interfaceinvoke v.<java.util.Map: void putAll(java.util.Map)>(v);
label:
v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: io.vertx.core.http.WebSocket webSocket> = v;
v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: java.lang.Integer subscriptionInitializationTimeout> = v;
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: java.util.Map uniOperations> = v;
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: java.util.Map multiOperations> = v;
v = specialinvoke v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: io.smallrye.mutiny.Uni initialize()>();
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: java.util.concurrent.CompletableFuture subscribeAsCompletionStage()>();
v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: java.util.concurrent.CompletableFuture initialization> = v;
v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: java.lang.Runnable onClose> = v;
v = new io.smallrye.graphql.client.vertx.websocket.opid.IncrementingNumberOperationIDGenerator;
specialinvoke v.<io.smallrye.graphql.client.vertx.websocket.opid.IncrementingNumberOperationIDGenerator: void <init>()>();
v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: io.smallrye.graphql.client.vertx.websocket.opid.OperationIDGenerator operationIdGenerator> = v;
return;
}
private io.smallrye.mutiny.Uni initialize()
{
java.util.function.Consumer v;
io.smallrye.mutiny.groups.UniCreate v;
io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler v;
io.smallrye.mutiny.Uni v;
v := @this: io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler;
v = staticinvoke <io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniCreate createFrom()>();
v = staticinvoke <io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler$lambda_initialize_9__1087: java.util.function.Consumer bootstrap$(io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler)>(v);
v = virtualinvoke v.<io.smallrye.mutiny.groups.UniCreate: io.smallrye.mutiny.Uni emitter(java.util.function.Consumer)>(v);
return v;
}
public io.smallrye.mutiny.Uni ensureInitialized()
{
io.smallrye.mutiny.groups.UniCreate v;
java.util.concurrent.CompletableFuture v;
io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler v;
io.smallrye.mutiny.Uni v;
v := @this: io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler;
v = staticinvoke <io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniCreate createFrom()>();
v = v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: java.util.concurrent.CompletableFuture initialization>;
v = virtualinvoke v.<io.smallrye.mutiny.groups.UniCreate: io.smallrye.mutiny.Uni completionStage(java.util.concurrent.CompletionStage)>(v);
return v;
}
public java.lang.String executeUni(jakarta.json.JsonObject, io.smallrye.mutiny.subscription.UniEmitter)
{
io.smallrye.mutiny.subscription.UniEmitter v;
io.smallrye.mutiny.Uni v;
java.util.function.Consumer v, v;
io.smallrye.graphql.client.vertx.websocket.opid.OperationIDGenerator v;
jakarta.json.JsonObject v;
io.smallrye.mutiny.groups.UniSubscribe v;
java.lang.String v;
io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler v;
v := @this: io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler;
v := @parameter: jakarta.json.JsonObject;
v := @parameter: io.smallrye.mutiny.subscription.UniEmitter;
v = v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: io.smallrye.graphql.client.vertx.websocket.opid.OperationIDGenerator operationIdGenerator>;
v = interfaceinvoke v.<io.smallrye.graphql.client.vertx.websocket.opid.OperationIDGenerator: java.lang.String generate()>();
v = virtualinvoke v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: io.smallrye.mutiny.Uni ensureInitialized()>();
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniSubscribe subscribe()>();
v = staticinvoke <io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler$lambda_executeUni_10__1088: java.util.function.Consumer bootstrap$(io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler,java.lang.String,io.smallrye.mutiny.subscription.UniEmitter,jakarta.json.JsonObject)>(v, v, v, v);
virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler$fail__1089: java.util.function.Consumer bootstrap$(io.smallrye.mutiny.subscription.UniEmitter)>(v);
virtualinvoke v.<io.smallrye.mutiny.groups.UniSubscribe: io.smallrye.mutiny.subscription.Cancellable 'with'(java.util.function.Consumer,java.util.function.Consumer)>(v, v);
return v;
}
public java.lang.String executeMulti(jakarta.json.JsonObject, io.smallrye.mutiny.subscription.MultiEmitter)
{
io.smallrye.mutiny.subscription.MultiEmitter v;
io.smallrye.mutiny.Uni v;
java.util.function.Consumer v, v;
io.smallrye.graphql.client.vertx.websocket.opid.OperationIDGenerator v;
jakarta.json.JsonObject v;
io.smallrye.mutiny.groups.UniSubscribe v;
java.lang.String v;
io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler v;
v := @this: io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler;
v := @parameter: jakarta.json.JsonObject;
v := @parameter: io.smallrye.mutiny.subscription.MultiEmitter;
v = v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: io.smallrye.graphql.client.vertx.websocket.opid.OperationIDGenerator operationIdGenerator>;
v = interfaceinvoke v.<io.smallrye.graphql.client.vertx.websocket.opid.OperationIDGenerator: java.lang.String generate()>();
v = virtualinvoke v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: io.smallrye.mutiny.Uni ensureInitialized()>();
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniSubscribe subscribe()>();
v = staticinvoke <io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler$lambda_executeMulti_11__1090: java.util.function.Consumer bootstrap$(io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler,java.lang.String,io.smallrye.mutiny.subscription.MultiEmitter,jakarta.json.JsonObject)>(v, v, v, v);
virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler$fail__1091: java.util.function.Consumer bootstrap$(io.smallrye.mutiny.subscription.MultiEmitter)>(v);
virtualinvoke v.<io.smallrye.mutiny.groups.UniSubscribe: io.smallrye.mutiny.subscription.Cancellable 'with'(java.util.function.Consumer,java.util.function.Consumer)>(v, v);
return v;
}
public void cancelUni(java.lang.String)
{
java.util.Map v;
jakarta.json.JsonObject v;
io.vertx.core.http.WebSocket v;
java.lang.String v;
io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler v;
v := @this: io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler;
v := @parameter: java.lang.String;
v = v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: java.util.Map uniOperations>;
interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
v = v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: io.vertx.core.http.WebSocket webSocket>;
v = specialinvoke v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: jakarta.json.JsonObject createStopMessage(java.lang.String)>(v);
specialinvoke v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: io.smallrye.mutiny.Uni send(io.vertx.core.http.WebSocket,jakarta.json.JsonObject)>(v, v);
return;
}
public void cancelMulti(java.lang.String)
{
java.util.Map v;
jakarta.json.JsonObject v;
io.vertx.core.http.WebSocket v;
java.lang.String v;
io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler v;
v := @this: io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler;
v := @parameter: java.lang.String;
v = v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: java.util.Map multiOperations>;
interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
v = v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: io.vertx.core.http.WebSocket webSocket>;
v = specialinvoke v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: jakarta.json.JsonObject createStopMessage(java.lang.String)>(v);
specialinvoke v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: io.smallrye.mutiny.Uni send(io.vertx.core.http.WebSocket,jakarta.json.JsonObject)>(v, v);
return;
}
public void close()
{
io.vertx.core.http.WebSocket v, v, v;
io.smallrye.mutiny.Uni v;
java.util.function.Consumer v;
jakarta.json.JsonObject v;
io.smallrye.mutiny.groups.UniSubscribe v;
io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler v;
boolean v;
v := @this: io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler;
v = v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: io.vertx.core.http.WebSocket webSocket>;
if v == null goto label;
v = v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: io.vertx.core.http.WebSocket webSocket>;
v = interfaceinvoke v.<io.vertx.core.http.WebSocket: boolean isClosed()>();
if v != 0 goto label;
v = v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: io.vertx.core.http.WebSocket webSocket>;
v = specialinvoke v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: jakarta.json.JsonObject createConnectionTerminateMessage()>();
v = specialinvoke v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: io.smallrye.mutiny.Uni send(io.vertx.core.http.WebSocket,jakarta.json.JsonObject)>(v, v);
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniSubscribe subscribe()>();
v = staticinvoke <io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler$lambda_close_12__1092: java.util.function.Consumer bootstrap$(io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler)>(v);
virtualinvoke v.<io.smallrye.mutiny.groups.UniSubscribe: io.smallrye.mutiny.subscription.Cancellable 'with'(java.util.function.Consumer)>(v);
label:
return;
}
private jakarta.json.JsonObject parseIncomingMessage(java.lang.String)
{
java.io.StringReader v;
jakarta.json.JsonObject v;
jakarta.json.JsonReader v;
java.lang.String v;
io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler v;
v := @this: io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler;
v := @parameter: java.lang.String;
v = new java.io.StringReader;
specialinvoke v.<java.io.StringReader: void <init>(java.lang.String)>(v);
v = staticinvoke <jakarta.json.Json: jakarta.json.JsonReader createReader(java.io.Reader)>(v);
v = interfaceinvoke v.<jakarta.json.JsonReader: jakarta.json.JsonObject readObject()>();
return v;
}
private io.smallrye.graphql.client.vertx.websocket.graphqlws.MessageType getMessageType(jakarta.json.JsonObject)
{
io.smallrye.graphql.client.vertx.websocket.graphqlws.MessageType v;
jakarta.json.JsonObject v;
java.lang.String v;
io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler v;
v := @this: io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler;
v := @parameter: jakarta.json.JsonObject;
v = interfaceinvoke v.<jakarta.json.JsonObject: java.lang.String getString(java.lang.String)>("type");
v = staticinvoke <io.smallrye.graphql.client.vertx.websocket.graphqlws.MessageType: io.smallrye.graphql.client.vertx.websocket.graphqlws.MessageType fromString(java.lang.String)>(v);
return v;
}
private io.smallrye.mutiny.Uni send(io.vertx.core.http.WebSocket, jakarta.json.JsonObject)
{
org.jboss.logging.Logger v, v;
io.vertx.core.http.WebSocket v;
io.vertx.core.Future v;
io.smallrye.mutiny.Uni v;
io.smallrye.mutiny.groups.UniCreate v;
java.util.concurrent.CompletionStage v;
jakarta.json.JsonObject v;
java.lang.String v, v;
io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler v;
boolean v;
v := @this: io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler;
v := @parameter: io.vertx.core.http.WebSocket;
v := @parameter: jakarta.json.JsonObject;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
v = <io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: org.jboss.logging.Logger log>;
v = virtualinvoke v.<org.jboss.logging.Logger: boolean isTraceEnabled()>();
if v == 0 goto label;
v = <io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: org.jboss.logging.Logger log>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>(">>> \u0001");
virtualinvoke v.<org.jboss.logging.Logger: void trace(java.lang.Object)>(v);
label:
v = staticinvoke <io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniCreate createFrom()>();
v = interfaceinvoke v.<io.vertx.core.http.WebSocket: io.vertx.core.Future writeTextMessage(java.lang.String)>(v);
v = interfaceinvoke v.<io.vertx.core.Future: java.util.concurrent.CompletionStage toCompletionStage()>();
v = virtualinvoke v.<io.smallrye.mutiny.groups.UniCreate: io.smallrye.mutiny.Uni completionStage(java.util.concurrent.CompletionStage)>(v);
return v;
}
private jakarta.json.JsonObject createConnectionInitMessage()
{
jakarta.json.JsonObjectBuilder v, v, v, v, v;
java.util.Map v, v;
jakarta.json.JsonObject v;
io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler v;
boolean v;
v := @this: io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler;
v = staticinvoke <jakarta.json.Json: jakarta.json.JsonObjectBuilder createObjectBuilder()>();
v = v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: java.util.Map initPayload>;
v = interfaceinvoke v.<java.util.Map: boolean isEmpty()>();
if v != 0 goto label;
v = v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: java.util.Map initPayload>;
v = staticinvoke <jakarta.json.Json: jakarta.json.JsonObjectBuilder createObjectBuilder(java.util.Map)>(v);
interfaceinvoke v.<jakarta.json.JsonObjectBuilder: jakarta.json.JsonObjectBuilder add(java.lang.String,jakarta.json.JsonObjectBuilder)>("payload", v);
label:
v = staticinvoke <jakarta.json.Json: jakarta.json.JsonObjectBuilder createObjectBuilder()>();
v = interfaceinvoke v.<jakarta.json.JsonObjectBuilder: jakarta.json.JsonObjectBuilder add(java.lang.String,java.lang.String)>("type", "connection_init");
v = interfaceinvoke v.<jakarta.json.JsonObjectBuilder: jakarta.json.JsonObjectBuilder addAll(jakarta.json.JsonObjectBuilder)>(v);
v = interfaceinvoke v.<jakarta.json.JsonObjectBuilder: jakarta.json.JsonObject build()>();
return v;
}
private jakarta.json.JsonObject createStopMessage(java.lang.String)
{
jakarta.json.JsonObjectBuilder v, v, v;
jakarta.json.JsonObject v;
java.lang.String v;
io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler v;
v := @this: io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler;
v := @parameter: java.lang.String;
v = staticinvoke <jakarta.json.Json: jakarta.json.JsonObjectBuilder createObjectBuilder()>();
v = interfaceinvoke v.<jakarta.json.JsonObjectBuilder: jakarta.json.JsonObjectBuilder add(java.lang.String,java.lang.String)>("type", "stop");
v = interfaceinvoke v.<jakarta.json.JsonObjectBuilder: jakarta.json.JsonObjectBuilder add(java.lang.String,java.lang.String)>("id", v);
v = interfaceinvoke v.<jakarta.json.JsonObjectBuilder: jakarta.json.JsonObject build()>();
return v;
}
private jakarta.json.JsonObject createConnectionTerminateMessage()
{
jakarta.json.JsonObjectBuilder v, v;
jakarta.json.JsonObject v;
io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler v;
v := @this: io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler;
v = staticinvoke <jakarta.json.Json: jakarta.json.JsonObjectBuilder createObjectBuilder()>();
v = interfaceinvoke v.<jakarta.json.JsonObjectBuilder: jakarta.json.JsonObjectBuilder add(java.lang.String,java.lang.String)>("type", "connection_terminate");
v = interfaceinvoke v.<jakarta.json.JsonObjectBuilder: jakarta.json.JsonObject build()>();
return v;
}
private jakarta.json.JsonObject createSubscribeMessage(jakarta.json.JsonObject, java.lang.String)
{
jakarta.json.JsonObjectBuilder v, v, v, v, v;
jakarta.json.JsonObject v, v, v;
java.lang.Object v;
java.lang.String v, v;
io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler v;
boolean v;
v := @this: io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler;
v := @parameter: jakarta.json.JsonObject;
v := @parameter: java.lang.String;
v = staticinvoke <jakarta.json.Json: jakarta.json.JsonObjectBuilder createObjectBuilder()>();
v = interfaceinvoke v.<jakarta.json.JsonObject: java.lang.String getString(java.lang.String)>("query");
interfaceinvoke v.<jakarta.json.JsonObjectBuilder: jakarta.json.JsonObjectBuilder add(java.lang.String,java.lang.String)>("query", v);
v = interfaceinvoke v.<jakarta.json.JsonObject: java.lang.Object get(java.lang.Object)>("operationName");
v = v instanceof jakarta.json.JsonString;
if v == 0 goto label;
interfaceinvoke v.<jakarta.json.JsonObjectBuilder: jakarta.json.JsonObjectBuilder add(java.lang.String,jakarta.json.JsonValue)>("operationName", v);
label:
v = interfaceinvoke v.<jakarta.json.JsonObject: jakarta.json.JsonObject getJsonObject(java.lang.String)>("variables");
if v == null goto label;
interfaceinvoke v.<jakarta.json.JsonObjectBuilder: jakarta.json.JsonObjectBuilder add(java.lang.String,jakarta.json.JsonValue)>("variables", v);
label:
v = staticinvoke <jakarta.json.Json: jakarta.json.JsonObjectBuilder createObjectBuilder()>();
v = interfaceinvoke v.<jakarta.json.JsonObjectBuilder: jakarta.json.JsonObjectBuilder add(java.lang.String,java.lang.String)>("type", "start");
v = interfaceinvoke v.<jakarta.json.JsonObjectBuilder: jakarta.json.JsonObjectBuilder add(java.lang.String,java.lang.String)>("id", v);
v = interfaceinvoke v.<jakarta.json.JsonObjectBuilder: jakarta.json.JsonObjectBuilder add(java.lang.String,jakarta.json.JsonObjectBuilder)>("payload", v);
v = interfaceinvoke v.<jakarta.json.JsonObjectBuilder: jakarta.json.JsonObject build()>();
return v;
}
public void failAllActiveOperationsWith(java.lang.Throwable)
{
java.lang.Throwable v;
org.jboss.logging.Logger v;
java.util.Map v, v, v, v;
io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler v;
boolean v, v;
java.util.Iterator v, v;
java.util.Set v, v;
java.lang.Object v, v, v, v;
v := @this: io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler;
v := @parameter: java.lang.Throwable;
v = <io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: org.jboss.logging.Logger log>;
virtualinvoke v.<org.jboss.logging.Logger: void debug(java.lang.Object)>("Failing all active operations");
v = v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: java.util.Map uniOperations>;
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: java.util.Map uniOperations>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
if v == null goto label;
interfaceinvoke v.<io.smallrye.mutiny.subscription.UniEmitter: void fail(java.lang.Throwable)>(v);
goto label;
label:
v = v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: java.util.Map multiOperations>;
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: java.util.Map multiOperations>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
if v == null goto label;
interfaceinvoke v.<io.smallrye.mutiny.subscription.MultiEmitter: void fail(java.lang.Throwable)>(v);
goto label;
label:
return;
}
private void handleData(java.lang.String, jakarta.json.JsonObject)
{
org.jboss.logging.Logger v, v, v, v;
java.util.Map v, v;
jakarta.json.JsonObject v;
java.lang.String v, v, v, v, v, v;
io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler v;
boolean v, v;
java.lang.Object v, v;
v := @this: io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler;
v := @parameter: java.lang.String;
v := @parameter: jakarta.json.JsonObject;
v = v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: java.util.Map uniOperations>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
if v == null goto label;
v = <io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: org.jboss.logging.Logger log>;
v = virtualinvoke v.<org.jboss.logging.Logger: boolean isTraceEnabled()>();
if v == 0 goto label;
v = <io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: org.jboss.logging.Logger log>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Received data for single-result operation \u0001");
virtualinvoke v.<org.jboss.logging.Logger: void trace(java.lang.Object)>(v);
label:
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
interfaceinvoke v.<io.smallrye.mutiny.subscription.UniEmitter: void complete(java.lang.Object)>(v);
goto label;
label:
v = v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: java.util.Map multiOperations>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v == null goto label;
v = interfaceinvoke v.<io.smallrye.mutiny.subscription.MultiEmitter: boolean isCancelled()>();
if v == 0 goto label;
v = <io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: org.jboss.logging.Logger log>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Received data for already cancelled operation \u0001");
virtualinvoke v.<org.jboss.logging.Logger: void warn(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
interfaceinvoke v.<io.smallrye.mutiny.subscription.MultiEmitter: io.smallrye.mutiny.subscription.MultiEmitter emit(java.lang.Object)>(v);
goto label;
label:
v = <io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: org.jboss.logging.Logger log>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Received event for an unknown subscription ID: \u0001");
virtualinvoke v.<org.jboss.logging.Logger: void warn(java.lang.Object)>(v);
label:
return;
}
private void handleOperationError(java.lang.String, jakarta.json.JsonObject)
{
io.smallrye.graphql.client.GraphQLClientException v;
io.smallrye.graphql.client.GraphQLError v;
java.util.Map v, v;
jakarta.json.JsonObject v;
java.lang.Object v, v;
java.lang.String v;
io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler v;
v := @this: io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler;
v := @parameter: java.lang.String;
v := @parameter: jakarta.json.JsonObject;
v = staticinvoke <io.smallrye.graphql.client.impl.ResponseReader: io.smallrye.graphql.client.GraphQLError readError(jakarta.json.JsonValue)>(v);
v = new io.smallrye.graphql.client.GraphQLClientException;
specialinvoke v.<io.smallrye.graphql.client.GraphQLClientException: void <init>(java.lang.String,io.smallrye.graphql.client.GraphQLError)>("Received an error", v);
v = v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: java.util.Map uniOperations>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
if v == null goto label;
interfaceinvoke v.<io.smallrye.mutiny.subscription.UniEmitter: void fail(java.lang.Throwable)>(v);
goto label;
label:
v = v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: java.util.Map multiOperations>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
if v == null goto label;
interfaceinvoke v.<io.smallrye.mutiny.subscription.MultiEmitter: void fail(java.lang.Throwable)>(v);
label:
return;
}
private void handleComplete(java.lang.String)
{
org.jboss.logging.Logger v;
java.util.Map v, v;
java.lang.Object v, v;
java.lang.String v, v;
io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler v;
io.smallrye.graphql.client.InvalidResponseException v;
v := @this: io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler;
v := @parameter: java.lang.String;
v = v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: java.util.Map uniOperations>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
if v == null goto label;
v = new io.smallrye.graphql.client.InvalidResponseException;
specialinvoke v.<io.smallrye.graphql.client.InvalidResponseException: void <init>(java.lang.String)>("Protocol error: received a \'complete\' message for this operation before the actual data");
interfaceinvoke v.<io.smallrye.mutiny.subscription.UniEmitter: void fail(java.lang.Throwable)>(v);
goto label;
label:
v = v.<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: java.util.Map multiOperations>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
if v == null goto label;
v = <io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: org.jboss.logging.Logger log>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Completed operation \u0001");
virtualinvoke v.<org.jboss.logging.Logger: void debug(java.lang.Object)>(v);
interfaceinvoke v.<io.smallrye.mutiny.subscription.MultiEmitter: void complete()>();
label:
return;
}
static void <clinit>()
{
org.jboss.logging.Logger v;
v = staticinvoke <org.jboss.logging.Logger: org.jboss.logging.Logger getLogger(java.lang.Class)>(class "Lio/smallrye/graphql/client/vertx/websocket/graphqlws/GraphQLWSSubprotocolHandler;");
<io.smallrye.graphql.client.vertx.websocket.graphqlws.GraphQLWSSubprotocolHandler: org.jboss.logging.Logger log> = v;
return;
}
}