class io.vertx.mutiny.core.http.WebSocketBaseImpl extends java.lang.Object implements io.vertx.mutiny.core.http.WebSocketBase
{
private final io.vertx.core.http.WebSocketBase delegate;
private io.smallrye.mutiny.Multi multi;
private io.vertx.mutiny.core.net.SocketAddress cached_0;
private io.vertx.mutiny.core.net.SocketAddress cached_1;
public io.vertx.core.http.WebSocketBase getDelegate()
{
io.vertx.core.http.WebSocketBase v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.core.http.WebSocketBase delegate>;
return v;
}
void <init>()
{
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.core.http.WebSocketBase delegate> = null;
return;
}
public void <init>(io.vertx.core.http.WebSocketBase)
{
io.vertx.core.http.WebSocketBase v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.core.http.WebSocketBase;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.core.http.WebSocketBase delegate> = v;
return;
}
public synchronized io.smallrye.mutiny.Multi toMulti()
{
io.vertx.core.http.WebSocketBase v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
java.util.function.Function v;
io.smallrye.mutiny.Multi v, v, v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Multi multi>;
if v != null goto label;
v = staticinvoke <io.vertx.mutiny.core.http.WebSocketBaseImpl$newInstance__2061: java.util.function.Function bootstrap$()>();
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.core.http.WebSocketBase delegate>;
v = staticinvoke <io.smallrye.mutiny.vertx.MultiHelper: io.smallrye.mutiny.Multi toMulti(io.vertx.core.streams.ReadStream,java.util.function.Function)>(v, v);
v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Multi multi> = v;
label:
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Multi multi>;
return v;
}
public java.lang.Iterable toBlockingIterable()
{
io.smallrye.mutiny.groups.MultiSubscribe v;
io.smallrye.mutiny.helpers.BlockingIterable v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Multi v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v = virtualinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Multi toMulti()>();
v = interfaceinvoke v.<io.smallrye.mutiny.Multi: io.smallrye.mutiny.groups.MultiSubscribe subscribe()>();
v = virtualinvoke v.<io.smallrye.mutiny.groups.MultiSubscribe: io.smallrye.mutiny.helpers.BlockingIterable asIterable()>();
return v;
}
public java.util.stream.Stream toBlockingStream()
{
io.smallrye.mutiny.groups.MultiSubscribe v;
java.util.stream.Stream v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Multi v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v = virtualinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Multi toMulti()>();
v = interfaceinvoke v.<io.smallrye.mutiny.Multi: io.smallrye.mutiny.groups.MultiSubscribe subscribe()>();
v = virtualinvoke v.<io.smallrye.mutiny.groups.MultiSubscribe: java.util.stream.Stream asStream()>();
return v;
}
public io.smallrye.mutiny.Uni write(io.vertx.mutiny.core.buffer.Buffer)
{
java.util.function.Consumer v;
io.vertx.mutiny.core.buffer.Buffer v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.mutiny.core.buffer.Buffer;
v = staticinvoke <io.vertx.mutiny.core.http.WebSocketBaseImpl$lambda_write_0__2062: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.http.WebSocketBaseImpl,io.vertx.mutiny.core.buffer.Buffer)>(v, v);
v = staticinvoke <io.smallrye.mutiny.vertx.AsyncResultUni: io.smallrye.mutiny.Uni toUni(java.util.function.Consumer)>(v);
return v;
}
public java.lang.Void writeAndAwait(io.vertx.mutiny.core.buffer.Buffer)
{
io.smallrye.mutiny.groups.UniAwait v;
io.vertx.mutiny.core.buffer.Buffer v;
java.lang.Object v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.mutiny.core.buffer.Buffer;
v = virtualinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Uni write(io.vertx.mutiny.core.buffer.Buffer)>(v);
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniAwait await()>();
v = virtualinvoke v.<io.smallrye.mutiny.groups.UniAwait: java.lang.Object indefinitely()>();
return v;
}
public void writeAndForget(io.vertx.mutiny.core.buffer.Buffer)
{
java.util.function.Consumer v;
io.vertx.mutiny.core.buffer.Buffer v;
io.smallrye.mutiny.groups.UniSubscribe v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.mutiny.core.buffer.Buffer;
v = virtualinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Uni write(io.vertx.mutiny.core.buffer.Buffer)>(v);
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniSubscribe subscribe()>();
v = <io.smallrye.mutiny.vertx.UniHelper: java.util.function.Consumer NOOP>;
virtualinvoke v.<io.smallrye.mutiny.groups.UniSubscribe: io.smallrye.mutiny.subscription.Cancellable 'with'(java.util.function.Consumer)>(v);
return;
}
public io.smallrye.mutiny.Uni end(io.vertx.mutiny.core.buffer.Buffer)
{
java.util.function.Consumer v;
io.vertx.mutiny.core.buffer.Buffer v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.mutiny.core.buffer.Buffer;
v = staticinvoke <io.vertx.mutiny.core.http.WebSocketBaseImpl$lambda_end_1__2063: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.http.WebSocketBaseImpl,io.vertx.mutiny.core.buffer.Buffer)>(v, v);
v = staticinvoke <io.smallrye.mutiny.vertx.AsyncResultUni: io.smallrye.mutiny.Uni toUni(java.util.function.Consumer)>(v);
return v;
}
public java.lang.Void endAndAwait(io.vertx.mutiny.core.buffer.Buffer)
{
io.smallrye.mutiny.groups.UniAwait v;
io.vertx.mutiny.core.buffer.Buffer v;
java.lang.Object v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.mutiny.core.buffer.Buffer;
v = virtualinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Uni end(io.vertx.mutiny.core.buffer.Buffer)>(v);
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniAwait await()>();
v = virtualinvoke v.<io.smallrye.mutiny.groups.UniAwait: java.lang.Object indefinitely()>();
return v;
}
public void endAndForget(io.vertx.mutiny.core.buffer.Buffer)
{
java.util.function.Consumer v;
io.vertx.mutiny.core.buffer.Buffer v;
io.smallrye.mutiny.groups.UniSubscribe v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.mutiny.core.buffer.Buffer;
v = virtualinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Uni end(io.vertx.mutiny.core.buffer.Buffer)>(v);
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniSubscribe subscribe()>();
v = <io.smallrye.mutiny.vertx.UniHelper: java.util.function.Consumer NOOP>;
virtualinvoke v.<io.smallrye.mutiny.groups.UniSubscribe: io.smallrye.mutiny.subscription.Cancellable 'with'(java.util.function.Consumer)>(v);
return;
}
public boolean writeQueueFull()
{
io.vertx.core.http.WebSocketBase v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
boolean v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.core.http.WebSocketBase delegate>;
v = interfaceinvoke v.<io.vertx.core.http.WebSocketBase: boolean writeQueueFull()>();
return v;
}
public io.vertx.mutiny.core.streams.Pipe pipe()
{
io.vertx.mutiny.core.streams.Pipe v;
io.vertx.core.streams.Pipe v;
io.vertx.core.http.WebSocketBase v;
io.smallrye.mutiny.vertx.TypeArg v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.core.http.WebSocketBase delegate>;
v = interfaceinvoke v.<io.vertx.core.http.WebSocketBase: io.vertx.core.streams.Pipe pipe()>();
v = <io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.vertx.TypeArg TYPE_ARG_0>;
v = staticinvoke <io.vertx.mutiny.core.streams.Pipe: io.vertx.mutiny.core.streams.Pipe newInstance(io.vertx.core.streams.Pipe,io.smallrye.mutiny.vertx.TypeArg)>(v, v);
return v;
}
public io.smallrye.mutiny.Uni pipeTo(io.vertx.mutiny.core.streams.WriteStream)
{
io.vertx.mutiny.core.streams.WriteStream v;
java.util.function.Consumer v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.mutiny.core.streams.WriteStream;
v = staticinvoke <io.vertx.mutiny.core.http.WebSocketBaseImpl$lambda_pipeTo_2__2064: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.http.WebSocketBaseImpl,io.vertx.mutiny.core.streams.WriteStream)>(v, v);
v = staticinvoke <io.smallrye.mutiny.vertx.AsyncResultUni: io.smallrye.mutiny.Uni toUni(java.util.function.Consumer)>(v);
return v;
}
public java.lang.Void pipeToAndAwait(io.vertx.mutiny.core.streams.WriteStream)
{
io.vertx.mutiny.core.streams.WriteStream v;
io.smallrye.mutiny.groups.UniAwait v;
java.lang.Object v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.mutiny.core.streams.WriteStream;
v = virtualinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Uni pipeTo(io.vertx.mutiny.core.streams.WriteStream)>(v);
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniAwait await()>();
v = virtualinvoke v.<io.smallrye.mutiny.groups.UniAwait: java.lang.Object indefinitely()>();
return v;
}
public void pipeToAndForget(io.vertx.mutiny.core.streams.WriteStream)
{
io.vertx.mutiny.core.streams.WriteStream v;
java.util.function.Consumer v;
io.smallrye.mutiny.groups.UniSubscribe v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.mutiny.core.streams.WriteStream;
v = virtualinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Uni pipeTo(io.vertx.mutiny.core.streams.WriteStream)>(v);
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniSubscribe subscribe()>();
v = <io.smallrye.mutiny.vertx.UniHelper: java.util.function.Consumer NOOP>;
virtualinvoke v.<io.smallrye.mutiny.groups.UniSubscribe: io.smallrye.mutiny.subscription.Cancellable 'with'(java.util.function.Consumer)>(v);
return;
}
private io.vertx.mutiny.core.http.WebSocketBase __exceptionHandler(io.vertx.core.Handler)
{
io.vertx.core.Handler v;
io.vertx.core.http.WebSocketBase v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.core.Handler;
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.core.http.WebSocketBase delegate>;
interfaceinvoke v.<io.vertx.core.http.WebSocketBase: io.vertx.core.http.WebSocketBase exceptionHandler(io.vertx.core.Handler)>(v);
return v;
}
public io.vertx.mutiny.core.http.WebSocketBase exceptionHandler(java.util.function.Consumer)
{
java.util.function.Consumer v;
io.smallrye.mutiny.vertx.DelegatingConsumerHandler v;
io.vertx.mutiny.core.http.WebSocketBase v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: java.util.function.Consumer;
if v == null goto label;
v = new io.smallrye.mutiny.vertx.DelegatingConsumerHandler;
specialinvoke v.<io.smallrye.mutiny.vertx.DelegatingConsumerHandler: void <init>(java.util.function.Consumer)>(v);
goto label;
label:
v = null;
label:
v = specialinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.mutiny.core.http.WebSocketBase __exceptionHandler(io.vertx.core.Handler)>(v);
return v;
}
private io.vertx.mutiny.core.http.WebSocketBase __handler(io.vertx.core.Handler)
{
io.vertx.core.http.WebSocketBase v;
io.smallrye.mutiny.vertx.DelegatingHandler v;
io.vertx.core.Handler v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
java.util.function.Function v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.core.Handler;
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.core.http.WebSocketBase delegate>;
v = new io.smallrye.mutiny.vertx.DelegatingHandler;
v = staticinvoke <io.vertx.mutiny.core.http.WebSocketBaseImpl$lambda___handler_3__2065: java.util.function.Function bootstrap$()>();
specialinvoke v.<io.smallrye.mutiny.vertx.DelegatingHandler: void <init>(io.vertx.core.Handler,java.util.function.Function)>(v, v);
interfaceinvoke v.<io.vertx.core.http.WebSocketBase: io.vertx.core.http.WebSocketBase handler(io.vertx.core.Handler)>(v);
return v;
}
public io.vertx.mutiny.core.http.WebSocketBase handler(java.util.function.Consumer)
{
java.util.function.Consumer v;
io.smallrye.mutiny.vertx.DelegatingConsumerHandler v;
io.vertx.mutiny.core.http.WebSocketBase v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: java.util.function.Consumer;
if v == null goto label;
v = new io.smallrye.mutiny.vertx.DelegatingConsumerHandler;
specialinvoke v.<io.smallrye.mutiny.vertx.DelegatingConsumerHandler: void <init>(java.util.function.Consumer)>(v);
goto label;
label:
v = null;
label:
v = specialinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.mutiny.core.http.WebSocketBase __handler(io.vertx.core.Handler)>(v);
return v;
}
public io.vertx.mutiny.core.http.WebSocketBase pause()
{
io.vertx.core.http.WebSocketBase v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.core.http.WebSocketBase delegate>;
interfaceinvoke v.<io.vertx.core.http.WebSocketBase: io.vertx.core.http.WebSocketBase pause()>();
return v;
}
public io.vertx.mutiny.core.http.WebSocketBase resume()
{
io.vertx.core.http.WebSocketBase v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.core.http.WebSocketBase delegate>;
interfaceinvoke v.<io.vertx.core.http.WebSocketBase: io.vertx.core.http.WebSocketBase resume()>();
return v;
}
public io.vertx.mutiny.core.http.WebSocketBase fetch(long)
{
long v;
io.vertx.core.http.WebSocketBase v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: long;
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.core.http.WebSocketBase delegate>;
interfaceinvoke v.<io.vertx.core.http.WebSocketBase: io.vertx.core.http.WebSocketBase fetch(long)>(v);
return v;
}
private io.vertx.mutiny.core.http.WebSocketBase __endHandler(io.vertx.core.Handler)
{
io.vertx.core.Handler v;
io.vertx.core.http.WebSocketBase v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.core.Handler;
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.core.http.WebSocketBase delegate>;
interfaceinvoke v.<io.vertx.core.http.WebSocketBase: io.vertx.core.http.WebSocketBase endHandler(io.vertx.core.Handler)>(v);
return v;
}
public io.vertx.mutiny.core.http.WebSocketBase endHandler(java.lang.Runnable)
{
io.vertx.mutiny.core.http.WebSocketBase v;
io.vertx.core.Handler v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
java.lang.Runnable v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: java.lang.Runnable;
v = staticinvoke <io.vertx.mutiny.core.http.WebSocketBaseImpl$lambda_endHandler_4__2066: io.vertx.core.Handler bootstrap$(java.lang.Runnable)>(v);
v = specialinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.mutiny.core.http.WebSocketBase __endHandler(io.vertx.core.Handler)>(v);
return v;
}
public io.vertx.mutiny.core.http.WebSocketBase setWriteQueueMaxSize(int)
{
int v;
io.vertx.core.http.WebSocketBase v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: int;
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.core.http.WebSocketBase delegate>;
interfaceinvoke v.<io.vertx.core.http.WebSocketBase: io.vertx.core.http.WebSocketBase setWriteQueueMaxSize(int)>(v);
return v;
}
private io.vertx.mutiny.core.http.WebSocketBase __drainHandler(io.vertx.core.Handler)
{
io.vertx.core.Handler v;
io.vertx.core.http.WebSocketBase v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.core.Handler;
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.core.http.WebSocketBase delegate>;
interfaceinvoke v.<io.vertx.core.http.WebSocketBase: io.vertx.core.http.WebSocketBase drainHandler(io.vertx.core.Handler)>(v);
return v;
}
public io.vertx.mutiny.core.http.WebSocketBase drainHandler(java.lang.Runnable)
{
io.vertx.mutiny.core.http.WebSocketBase v;
io.vertx.core.Handler v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
java.lang.Runnable v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: java.lang.Runnable;
v = staticinvoke <io.vertx.mutiny.core.http.WebSocketBaseImpl$lambda_drainHandler_5__2067: io.vertx.core.Handler bootstrap$(java.lang.Runnable)>(v);
v = specialinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.mutiny.core.http.WebSocketBase __drainHandler(io.vertx.core.Handler)>(v);
return v;
}
public java.lang.String binaryHandlerID()
{
java.lang.String v;
io.vertx.core.http.WebSocketBase v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.core.http.WebSocketBase delegate>;
v = interfaceinvoke v.<io.vertx.core.http.WebSocketBase: java.lang.String binaryHandlerID()>();
return v;
}
public java.lang.String textHandlerID()
{
java.lang.String v;
io.vertx.core.http.WebSocketBase v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.core.http.WebSocketBase delegate>;
v = interfaceinvoke v.<io.vertx.core.http.WebSocketBase: java.lang.String textHandlerID()>();
return v;
}
public java.lang.String subProtocol()
{
java.lang.String v;
io.vertx.core.http.WebSocketBase v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.core.http.WebSocketBase delegate>;
v = interfaceinvoke v.<io.vertx.core.http.WebSocketBase: java.lang.String subProtocol()>();
return v;
}
public java.lang.Short closeStatusCode()
{
io.vertx.core.http.WebSocketBase v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
java.lang.Short v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.core.http.WebSocketBase delegate>;
v = interfaceinvoke v.<io.vertx.core.http.WebSocketBase: java.lang.Short closeStatusCode()>();
return v;
}
public java.lang.String closeReason()
{
java.lang.String v;
io.vertx.core.http.WebSocketBase v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.core.http.WebSocketBase delegate>;
v = interfaceinvoke v.<io.vertx.core.http.WebSocketBase: java.lang.String closeReason()>();
return v;
}
public io.vertx.mutiny.core.MultiMap headers()
{
io.vertx.core.http.WebSocketBase v;
io.vertx.core.MultiMap v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.vertx.mutiny.core.MultiMap v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.core.http.WebSocketBase delegate>;
v = interfaceinvoke v.<io.vertx.core.http.WebSocketBase: io.vertx.core.MultiMap headers()>();
v = staticinvoke <io.vertx.mutiny.core.MultiMap: io.vertx.mutiny.core.MultiMap newInstance(io.vertx.core.MultiMap)>(v);
return v;
}
public io.smallrye.mutiny.Uni writeFrame(io.vertx.mutiny.core.http.WebSocketFrame)
{
java.util.function.Consumer v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
io.vertx.mutiny.core.http.WebSocketFrame v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.mutiny.core.http.WebSocketFrame;
v = staticinvoke <io.vertx.mutiny.core.http.WebSocketBaseImpl$lambda_writeFrame_6__2068: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.http.WebSocketBaseImpl,io.vertx.mutiny.core.http.WebSocketFrame)>(v, v);
v = staticinvoke <io.smallrye.mutiny.vertx.AsyncResultUni: io.smallrye.mutiny.Uni toUni(java.util.function.Consumer)>(v);
return v;
}
public java.lang.Void writeFrameAndAwait(io.vertx.mutiny.core.http.WebSocketFrame)
{
io.smallrye.mutiny.groups.UniAwait v;
java.lang.Object v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
io.vertx.mutiny.core.http.WebSocketFrame v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.mutiny.core.http.WebSocketFrame;
v = virtualinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Uni writeFrame(io.vertx.mutiny.core.http.WebSocketFrame)>(v);
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniAwait await()>();
v = virtualinvoke v.<io.smallrye.mutiny.groups.UniAwait: java.lang.Object indefinitely()>();
return v;
}
public io.vertx.mutiny.core.http.WebSocketBase writeFrameAndForget(io.vertx.mutiny.core.http.WebSocketFrame)
{
java.util.function.Consumer v;
io.smallrye.mutiny.groups.UniSubscribe v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
io.vertx.mutiny.core.http.WebSocketFrame v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.mutiny.core.http.WebSocketFrame;
v = virtualinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Uni writeFrame(io.vertx.mutiny.core.http.WebSocketFrame)>(v);
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniSubscribe subscribe()>();
v = <io.smallrye.mutiny.vertx.UniHelper: java.util.function.Consumer NOOP>;
virtualinvoke v.<io.smallrye.mutiny.groups.UniSubscribe: io.smallrye.mutiny.subscription.Cancellable 'with'(java.util.function.Consumer)>(v);
return v;
}
public io.smallrye.mutiny.Uni writeFinalTextFrame(java.lang.String)
{
java.util.function.Consumer v;
java.lang.String v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: java.lang.String;
v = staticinvoke <io.vertx.mutiny.core.http.WebSocketBaseImpl$lambda_writeFinalTextFrame_7__2069: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.http.WebSocketBaseImpl,java.lang.String)>(v, v);
v = staticinvoke <io.smallrye.mutiny.vertx.AsyncResultUni: io.smallrye.mutiny.Uni toUni(java.util.function.Consumer)>(v);
return v;
}
public java.lang.Void writeFinalTextFrameAndAwait(java.lang.String)
{
io.smallrye.mutiny.groups.UniAwait v;
java.lang.Object v;
java.lang.String v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: java.lang.String;
v = virtualinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Uni writeFinalTextFrame(java.lang.String)>(v);
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniAwait await()>();
v = virtualinvoke v.<io.smallrye.mutiny.groups.UniAwait: java.lang.Object indefinitely()>();
return v;
}
public io.vertx.mutiny.core.http.WebSocketBase writeFinalTextFrameAndForget(java.lang.String)
{
java.util.function.Consumer v;
io.smallrye.mutiny.groups.UniSubscribe v;
java.lang.String v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: java.lang.String;
v = virtualinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Uni writeFinalTextFrame(java.lang.String)>(v);
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniSubscribe subscribe()>();
v = <io.smallrye.mutiny.vertx.UniHelper: java.util.function.Consumer NOOP>;
virtualinvoke v.<io.smallrye.mutiny.groups.UniSubscribe: io.smallrye.mutiny.subscription.Cancellable 'with'(java.util.function.Consumer)>(v);
return v;
}
public io.smallrye.mutiny.Uni writeFinalBinaryFrame(io.vertx.mutiny.core.buffer.Buffer)
{
java.util.function.Consumer v;
io.vertx.mutiny.core.buffer.Buffer v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.mutiny.core.buffer.Buffer;
v = staticinvoke <io.vertx.mutiny.core.http.WebSocketBaseImpl$lambda_writeFinalBinaryFrame_8__2070: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.http.WebSocketBaseImpl,io.vertx.mutiny.core.buffer.Buffer)>(v, v);
v = staticinvoke <io.smallrye.mutiny.vertx.AsyncResultUni: io.smallrye.mutiny.Uni toUni(java.util.function.Consumer)>(v);
return v;
}
public java.lang.Void writeFinalBinaryFrameAndAwait(io.vertx.mutiny.core.buffer.Buffer)
{
io.smallrye.mutiny.groups.UniAwait v;
io.vertx.mutiny.core.buffer.Buffer v;
java.lang.Object v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.mutiny.core.buffer.Buffer;
v = virtualinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Uni writeFinalBinaryFrame(io.vertx.mutiny.core.buffer.Buffer)>(v);
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniAwait await()>();
v = virtualinvoke v.<io.smallrye.mutiny.groups.UniAwait: java.lang.Object indefinitely()>();
return v;
}
public io.vertx.mutiny.core.http.WebSocketBase writeFinalBinaryFrameAndForget(io.vertx.mutiny.core.buffer.Buffer)
{
java.util.function.Consumer v;
io.vertx.mutiny.core.buffer.Buffer v;
io.smallrye.mutiny.groups.UniSubscribe v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.mutiny.core.buffer.Buffer;
v = virtualinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Uni writeFinalBinaryFrame(io.vertx.mutiny.core.buffer.Buffer)>(v);
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniSubscribe subscribe()>();
v = <io.smallrye.mutiny.vertx.UniHelper: java.util.function.Consumer NOOP>;
virtualinvoke v.<io.smallrye.mutiny.groups.UniSubscribe: io.smallrye.mutiny.subscription.Cancellable 'with'(java.util.function.Consumer)>(v);
return v;
}
public io.smallrye.mutiny.Uni writeBinaryMessage(io.vertx.mutiny.core.buffer.Buffer)
{
java.util.function.Consumer v;
io.vertx.mutiny.core.buffer.Buffer v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.mutiny.core.buffer.Buffer;
v = staticinvoke <io.vertx.mutiny.core.http.WebSocketBaseImpl$lambda_writeBinaryMessage_9__2071: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.http.WebSocketBaseImpl,io.vertx.mutiny.core.buffer.Buffer)>(v, v);
v = staticinvoke <io.smallrye.mutiny.vertx.AsyncResultUni: io.smallrye.mutiny.Uni toUni(java.util.function.Consumer)>(v);
return v;
}
public java.lang.Void writeBinaryMessageAndAwait(io.vertx.mutiny.core.buffer.Buffer)
{
io.smallrye.mutiny.groups.UniAwait v;
io.vertx.mutiny.core.buffer.Buffer v;
java.lang.Object v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.mutiny.core.buffer.Buffer;
v = virtualinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Uni writeBinaryMessage(io.vertx.mutiny.core.buffer.Buffer)>(v);
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniAwait await()>();
v = virtualinvoke v.<io.smallrye.mutiny.groups.UniAwait: java.lang.Object indefinitely()>();
return v;
}
public io.vertx.mutiny.core.http.WebSocketBase writeBinaryMessageAndForget(io.vertx.mutiny.core.buffer.Buffer)
{
java.util.function.Consumer v;
io.vertx.mutiny.core.buffer.Buffer v;
io.smallrye.mutiny.groups.UniSubscribe v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.mutiny.core.buffer.Buffer;
v = virtualinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Uni writeBinaryMessage(io.vertx.mutiny.core.buffer.Buffer)>(v);
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniSubscribe subscribe()>();
v = <io.smallrye.mutiny.vertx.UniHelper: java.util.function.Consumer NOOP>;
virtualinvoke v.<io.smallrye.mutiny.groups.UniSubscribe: io.smallrye.mutiny.subscription.Cancellable 'with'(java.util.function.Consumer)>(v);
return v;
}
public io.smallrye.mutiny.Uni writeTextMessage(java.lang.String)
{
java.util.function.Consumer v;
java.lang.String v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: java.lang.String;
v = staticinvoke <io.vertx.mutiny.core.http.WebSocketBaseImpl$lambda_writeTextMessage_10__2072: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.http.WebSocketBaseImpl,java.lang.String)>(v, v);
v = staticinvoke <io.smallrye.mutiny.vertx.AsyncResultUni: io.smallrye.mutiny.Uni toUni(java.util.function.Consumer)>(v);
return v;
}
public java.lang.Void writeTextMessageAndAwait(java.lang.String)
{
io.smallrye.mutiny.groups.UniAwait v;
java.lang.Object v;
java.lang.String v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: java.lang.String;
v = virtualinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Uni writeTextMessage(java.lang.String)>(v);
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniAwait await()>();
v = virtualinvoke v.<io.smallrye.mutiny.groups.UniAwait: java.lang.Object indefinitely()>();
return v;
}
public io.vertx.mutiny.core.http.WebSocketBase writeTextMessageAndForget(java.lang.String)
{
java.util.function.Consumer v;
io.smallrye.mutiny.groups.UniSubscribe v;
java.lang.String v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: java.lang.String;
v = virtualinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Uni writeTextMessage(java.lang.String)>(v);
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniSubscribe subscribe()>();
v = <io.smallrye.mutiny.vertx.UniHelper: java.util.function.Consumer NOOP>;
virtualinvoke v.<io.smallrye.mutiny.groups.UniSubscribe: io.smallrye.mutiny.subscription.Cancellable 'with'(java.util.function.Consumer)>(v);
return v;
}
public io.smallrye.mutiny.Uni writePing(io.vertx.mutiny.core.buffer.Buffer)
{
java.util.function.Consumer v;
io.vertx.mutiny.core.buffer.Buffer v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.mutiny.core.buffer.Buffer;
v = staticinvoke <io.vertx.mutiny.core.http.WebSocketBaseImpl$lambda_writePing_11__2073: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.http.WebSocketBaseImpl,io.vertx.mutiny.core.buffer.Buffer)>(v, v);
v = staticinvoke <io.smallrye.mutiny.vertx.AsyncResultUni: io.smallrye.mutiny.Uni toUni(java.util.function.Consumer)>(v);
return v;
}
public java.lang.Void writePingAndAwait(io.vertx.mutiny.core.buffer.Buffer)
{
io.smallrye.mutiny.groups.UniAwait v;
io.vertx.mutiny.core.buffer.Buffer v;
java.lang.Object v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.mutiny.core.buffer.Buffer;
v = virtualinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Uni writePing(io.vertx.mutiny.core.buffer.Buffer)>(v);
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniAwait await()>();
v = virtualinvoke v.<io.smallrye.mutiny.groups.UniAwait: java.lang.Object indefinitely()>();
return v;
}
public io.vertx.mutiny.core.http.WebSocketBase writePingAndForget(io.vertx.mutiny.core.buffer.Buffer)
{
java.util.function.Consumer v;
io.vertx.mutiny.core.buffer.Buffer v;
io.smallrye.mutiny.groups.UniSubscribe v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.mutiny.core.buffer.Buffer;
v = virtualinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Uni writePing(io.vertx.mutiny.core.buffer.Buffer)>(v);
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniSubscribe subscribe()>();
v = <io.smallrye.mutiny.vertx.UniHelper: java.util.function.Consumer NOOP>;
virtualinvoke v.<io.smallrye.mutiny.groups.UniSubscribe: io.smallrye.mutiny.subscription.Cancellable 'with'(java.util.function.Consumer)>(v);
return v;
}
public io.smallrye.mutiny.Uni writePong(io.vertx.mutiny.core.buffer.Buffer)
{
java.util.function.Consumer v;
io.vertx.mutiny.core.buffer.Buffer v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.mutiny.core.buffer.Buffer;
v = staticinvoke <io.vertx.mutiny.core.http.WebSocketBaseImpl$lambda_writePong_12__2074: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.http.WebSocketBaseImpl,io.vertx.mutiny.core.buffer.Buffer)>(v, v);
v = staticinvoke <io.smallrye.mutiny.vertx.AsyncResultUni: io.smallrye.mutiny.Uni toUni(java.util.function.Consumer)>(v);
return v;
}
public java.lang.Void writePongAndAwait(io.vertx.mutiny.core.buffer.Buffer)
{
io.smallrye.mutiny.groups.UniAwait v;
io.vertx.mutiny.core.buffer.Buffer v;
java.lang.Object v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.mutiny.core.buffer.Buffer;
v = virtualinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Uni writePong(io.vertx.mutiny.core.buffer.Buffer)>(v);
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniAwait await()>();
v = virtualinvoke v.<io.smallrye.mutiny.groups.UniAwait: java.lang.Object indefinitely()>();
return v;
}
public io.vertx.mutiny.core.http.WebSocketBase writePongAndForget(io.vertx.mutiny.core.buffer.Buffer)
{
java.util.function.Consumer v;
io.vertx.mutiny.core.buffer.Buffer v;
io.smallrye.mutiny.groups.UniSubscribe v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.mutiny.core.buffer.Buffer;
v = virtualinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Uni writePong(io.vertx.mutiny.core.buffer.Buffer)>(v);
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniSubscribe subscribe()>();
v = <io.smallrye.mutiny.vertx.UniHelper: java.util.function.Consumer NOOP>;
virtualinvoke v.<io.smallrye.mutiny.groups.UniSubscribe: io.smallrye.mutiny.subscription.Cancellable 'with'(java.util.function.Consumer)>(v);
return v;
}
private io.vertx.mutiny.core.http.WebSocketBase __closeHandler(io.vertx.core.Handler)
{
io.vertx.core.Handler v;
io.vertx.core.http.WebSocketBase v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.core.Handler;
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.core.http.WebSocketBase delegate>;
interfaceinvoke v.<io.vertx.core.http.WebSocketBase: io.vertx.core.http.WebSocketBase closeHandler(io.vertx.core.Handler)>(v);
return v;
}
public io.vertx.mutiny.core.http.WebSocketBase closeHandler(java.lang.Runnable)
{
io.vertx.mutiny.core.http.WebSocketBase v;
io.vertx.core.Handler v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
java.lang.Runnable v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: java.lang.Runnable;
v = staticinvoke <io.vertx.mutiny.core.http.WebSocketBaseImpl$lambda_closeHandler_13__2075: io.vertx.core.Handler bootstrap$(java.lang.Runnable)>(v);
v = specialinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.mutiny.core.http.WebSocketBase __closeHandler(io.vertx.core.Handler)>(v);
return v;
}
private io.vertx.mutiny.core.http.WebSocketBase __frameHandler(io.vertx.core.Handler)
{
io.vertx.core.http.WebSocketBase v;
io.smallrye.mutiny.vertx.DelegatingHandler v;
io.vertx.core.Handler v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
java.util.function.Function v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.core.Handler;
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.core.http.WebSocketBase delegate>;
v = new io.smallrye.mutiny.vertx.DelegatingHandler;
v = staticinvoke <io.vertx.mutiny.core.http.WebSocketBaseImpl$lambda___frameHandler_14__2076: java.util.function.Function bootstrap$()>();
specialinvoke v.<io.smallrye.mutiny.vertx.DelegatingHandler: void <init>(io.vertx.core.Handler,java.util.function.Function)>(v, v);
interfaceinvoke v.<io.vertx.core.http.WebSocketBase: io.vertx.core.http.WebSocketBase frameHandler(io.vertx.core.Handler)>(v);
return v;
}
public io.vertx.mutiny.core.http.WebSocketBase frameHandler(java.util.function.Consumer)
{
java.util.function.Consumer v;
io.smallrye.mutiny.vertx.DelegatingConsumerHandler v;
io.vertx.mutiny.core.http.WebSocketBase v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: java.util.function.Consumer;
if v == null goto label;
v = new io.smallrye.mutiny.vertx.DelegatingConsumerHandler;
specialinvoke v.<io.smallrye.mutiny.vertx.DelegatingConsumerHandler: void <init>(java.util.function.Consumer)>(v);
goto label;
label:
v = null;
label:
v = specialinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.mutiny.core.http.WebSocketBase __frameHandler(io.vertx.core.Handler)>(v);
return v;
}
private io.vertx.mutiny.core.http.WebSocketBase __textMessageHandler(io.vertx.core.Handler)
{
io.vertx.core.Handler v;
io.vertx.core.http.WebSocketBase v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.core.Handler;
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.core.http.WebSocketBase delegate>;
interfaceinvoke v.<io.vertx.core.http.WebSocketBase: io.vertx.core.http.WebSocketBase textMessageHandler(io.vertx.core.Handler)>(v);
return v;
}
public io.vertx.mutiny.core.http.WebSocketBase textMessageHandler(java.util.function.Consumer)
{
java.util.function.Consumer v;
io.smallrye.mutiny.vertx.DelegatingConsumerHandler v;
io.vertx.mutiny.core.http.WebSocketBase v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: java.util.function.Consumer;
if v == null goto label;
v = new io.smallrye.mutiny.vertx.DelegatingConsumerHandler;
specialinvoke v.<io.smallrye.mutiny.vertx.DelegatingConsumerHandler: void <init>(java.util.function.Consumer)>(v);
goto label;
label:
v = null;
label:
v = specialinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.mutiny.core.http.WebSocketBase __textMessageHandler(io.vertx.core.Handler)>(v);
return v;
}
private io.vertx.mutiny.core.http.WebSocketBase __binaryMessageHandler(io.vertx.core.Handler)
{
io.vertx.core.http.WebSocketBase v;
io.smallrye.mutiny.vertx.DelegatingHandler v;
io.vertx.core.Handler v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
java.util.function.Function v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.core.Handler;
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.core.http.WebSocketBase delegate>;
v = new io.smallrye.mutiny.vertx.DelegatingHandler;
v = staticinvoke <io.vertx.mutiny.core.http.WebSocketBaseImpl$lambda___binaryMessageHandler_15__2077: java.util.function.Function bootstrap$()>();
specialinvoke v.<io.smallrye.mutiny.vertx.DelegatingHandler: void <init>(io.vertx.core.Handler,java.util.function.Function)>(v, v);
interfaceinvoke v.<io.vertx.core.http.WebSocketBase: io.vertx.core.http.WebSocketBase binaryMessageHandler(io.vertx.core.Handler)>(v);
return v;
}
public io.vertx.mutiny.core.http.WebSocketBase binaryMessageHandler(java.util.function.Consumer)
{
java.util.function.Consumer v;
io.smallrye.mutiny.vertx.DelegatingConsumerHandler v;
io.vertx.mutiny.core.http.WebSocketBase v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: java.util.function.Consumer;
if v == null goto label;
v = new io.smallrye.mutiny.vertx.DelegatingConsumerHandler;
specialinvoke v.<io.smallrye.mutiny.vertx.DelegatingConsumerHandler: void <init>(java.util.function.Consumer)>(v);
goto label;
label:
v = null;
label:
v = specialinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.mutiny.core.http.WebSocketBase __binaryMessageHandler(io.vertx.core.Handler)>(v);
return v;
}
private io.vertx.mutiny.core.http.WebSocketBase __pongHandler(io.vertx.core.Handler)
{
io.vertx.core.http.WebSocketBase v;
io.smallrye.mutiny.vertx.DelegatingHandler v;
io.vertx.core.Handler v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
java.util.function.Function v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: io.vertx.core.Handler;
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.core.http.WebSocketBase delegate>;
v = new io.smallrye.mutiny.vertx.DelegatingHandler;
v = staticinvoke <io.vertx.mutiny.core.http.WebSocketBaseImpl$lambda___pongHandler_16__2078: java.util.function.Function bootstrap$()>();
specialinvoke v.<io.smallrye.mutiny.vertx.DelegatingHandler: void <init>(io.vertx.core.Handler,java.util.function.Function)>(v, v);
interfaceinvoke v.<io.vertx.core.http.WebSocketBase: io.vertx.core.http.WebSocketBase pongHandler(io.vertx.core.Handler)>(v);
return v;
}
public io.vertx.mutiny.core.http.WebSocketBase pongHandler(java.util.function.Consumer)
{
java.util.function.Consumer v;
io.smallrye.mutiny.vertx.DelegatingConsumerHandler v;
io.vertx.mutiny.core.http.WebSocketBase v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: java.util.function.Consumer;
if v == null goto label;
v = new io.smallrye.mutiny.vertx.DelegatingConsumerHandler;
specialinvoke v.<io.smallrye.mutiny.vertx.DelegatingConsumerHandler: void <init>(java.util.function.Consumer)>(v);
goto label;
label:
v = null;
label:
v = specialinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.mutiny.core.http.WebSocketBase __pongHandler(io.vertx.core.Handler)>(v);
return v;
}
public io.smallrye.mutiny.Uni end()
{
java.util.function.Consumer v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v = staticinvoke <io.vertx.mutiny.core.http.WebSocketBaseImpl$lambda_end_17__2079: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.http.WebSocketBaseImpl)>(v);
v = staticinvoke <io.smallrye.mutiny.vertx.AsyncResultUni: io.smallrye.mutiny.Uni toUni(java.util.function.Consumer)>(v);
return v;
}
public java.lang.Void endAndAwait()
{
io.smallrye.mutiny.groups.UniAwait v;
java.lang.Object v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v = virtualinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Uni end()>();
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniAwait await()>();
v = virtualinvoke v.<io.smallrye.mutiny.groups.UniAwait: java.lang.Object indefinitely()>();
return v;
}
public void endAndForget()
{
java.util.function.Consumer v;
io.smallrye.mutiny.groups.UniSubscribe v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v = virtualinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Uni end()>();
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniSubscribe subscribe()>();
v = <io.smallrye.mutiny.vertx.UniHelper: java.util.function.Consumer NOOP>;
virtualinvoke v.<io.smallrye.mutiny.groups.UniSubscribe: io.smallrye.mutiny.subscription.Cancellable 'with'(java.util.function.Consumer)>(v);
return;
}
public io.smallrye.mutiny.Uni close()
{
java.util.function.Consumer v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v = staticinvoke <io.vertx.mutiny.core.http.WebSocketBaseImpl$lambda_close_18__2080: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.http.WebSocketBaseImpl)>(v);
v = staticinvoke <io.smallrye.mutiny.vertx.AsyncResultUni: io.smallrye.mutiny.Uni toUni(java.util.function.Consumer)>(v);
return v;
}
public java.lang.Void closeAndAwait()
{
io.smallrye.mutiny.groups.UniAwait v;
java.lang.Object v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v = virtualinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Uni close()>();
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniAwait await()>();
v = virtualinvoke v.<io.smallrye.mutiny.groups.UniAwait: java.lang.Object indefinitely()>();
return v;
}
public void closeAndForget()
{
java.util.function.Consumer v;
io.smallrye.mutiny.groups.UniSubscribe v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v = virtualinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Uni close()>();
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniSubscribe subscribe()>();
v = <io.smallrye.mutiny.vertx.UniHelper: java.util.function.Consumer NOOP>;
virtualinvoke v.<io.smallrye.mutiny.groups.UniSubscribe: io.smallrye.mutiny.subscription.Cancellable 'with'(java.util.function.Consumer)>(v);
return;
}
public io.smallrye.mutiny.Uni close(short)
{
java.util.function.Consumer v;
short v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: short;
v = staticinvoke <io.vertx.mutiny.core.http.WebSocketBaseImpl$lambda_close_19__2081: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.http.WebSocketBaseImpl,short)>(v, v);
v = staticinvoke <io.smallrye.mutiny.vertx.AsyncResultUni: io.smallrye.mutiny.Uni toUni(java.util.function.Consumer)>(v);
return v;
}
public java.lang.Void closeAndAwait(short)
{
io.smallrye.mutiny.groups.UniAwait v;
short v;
java.lang.Object v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: short;
v = virtualinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Uni close(short)>(v);
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniAwait await()>();
v = virtualinvoke v.<io.smallrye.mutiny.groups.UniAwait: java.lang.Object indefinitely()>();
return v;
}
public void closeAndForget(short)
{
java.util.function.Consumer v;
short v;
io.smallrye.mutiny.groups.UniSubscribe v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: short;
v = virtualinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Uni close(short)>(v);
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniSubscribe subscribe()>();
v = <io.smallrye.mutiny.vertx.UniHelper: java.util.function.Consumer NOOP>;
virtualinvoke v.<io.smallrye.mutiny.groups.UniSubscribe: io.smallrye.mutiny.subscription.Cancellable 'with'(java.util.function.Consumer)>(v);
return;
}
public io.smallrye.mutiny.Uni close(short, java.lang.String)
{
java.util.function.Consumer v;
short v;
java.lang.String v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: short;
v := @parameter: java.lang.String;
v = staticinvoke <io.vertx.mutiny.core.http.WebSocketBaseImpl$lambda_close_20__2082: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.http.WebSocketBaseImpl,short,java.lang.String)>(v, v, v);
v = staticinvoke <io.smallrye.mutiny.vertx.AsyncResultUni: io.smallrye.mutiny.Uni toUni(java.util.function.Consumer)>(v);
return v;
}
public java.lang.Void closeAndAwait(short, java.lang.String)
{
io.smallrye.mutiny.groups.UniAwait v;
short v;
java.lang.Object v;
java.lang.String v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: short;
v := @parameter: java.lang.String;
v = virtualinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Uni close(short,java.lang.String)>(v, v);
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniAwait await()>();
v = virtualinvoke v.<io.smallrye.mutiny.groups.UniAwait: java.lang.Object indefinitely()>();
return v;
}
public void closeAndForget(short, java.lang.String)
{
java.util.function.Consumer v;
short v;
io.smallrye.mutiny.groups.UniSubscribe v;
java.lang.String v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v := @parameter: short;
v := @parameter: java.lang.String;
v = virtualinvoke v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.smallrye.mutiny.Uni close(short,java.lang.String)>(v, v);
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniSubscribe subscribe()>();
v = <io.smallrye.mutiny.vertx.UniHelper: java.util.function.Consumer NOOP>;
virtualinvoke v.<io.smallrye.mutiny.groups.UniSubscribe: io.smallrye.mutiny.subscription.Cancellable 'with'(java.util.function.Consumer)>(v);
return;
}
public io.vertx.mutiny.core.net.SocketAddress remoteAddress()
{
io.vertx.core.http.WebSocketBase v;
io.vertx.mutiny.core.net.SocketAddress v, v, v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.vertx.core.net.SocketAddress v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.mutiny.core.net.SocketAddress cached_0>;
if v == null goto label;
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.mutiny.core.net.SocketAddress cached_0>;
return v;
label:
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.core.http.WebSocketBase delegate>;
v = interfaceinvoke v.<io.vertx.core.http.WebSocketBase: io.vertx.core.net.SocketAddress remoteAddress()>();
v = staticinvoke <io.vertx.mutiny.core.net.SocketAddress: io.vertx.mutiny.core.net.SocketAddress newInstance(io.vertx.core.net.SocketAddress)>(v);
v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.mutiny.core.net.SocketAddress cached_0> = v;
return v;
}
public io.vertx.mutiny.core.net.SocketAddress localAddress()
{
io.vertx.core.http.WebSocketBase v;
io.vertx.mutiny.core.net.SocketAddress v, v, v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
io.vertx.core.net.SocketAddress v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.mutiny.core.net.SocketAddress cached_1>;
if v == null goto label;
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.mutiny.core.net.SocketAddress cached_1>;
return v;
label:
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.core.http.WebSocketBase delegate>;
v = interfaceinvoke v.<io.vertx.core.http.WebSocketBase: io.vertx.core.net.SocketAddress localAddress()>();
v = staticinvoke <io.vertx.mutiny.core.net.SocketAddress: io.vertx.mutiny.core.net.SocketAddress newInstance(io.vertx.core.net.SocketAddress)>(v);
v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.mutiny.core.net.SocketAddress cached_1> = v;
return v;
}
public boolean isSsl()
{
io.vertx.core.http.WebSocketBase v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
boolean v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.core.http.WebSocketBase delegate>;
v = interfaceinvoke v.<io.vertx.core.http.WebSocketBase: boolean isSsl()>();
return v;
}
public boolean isClosed()
{
io.vertx.core.http.WebSocketBase v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
boolean v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.core.http.WebSocketBase delegate>;
v = interfaceinvoke v.<io.vertx.core.http.WebSocketBase: boolean isClosed()>();
return v;
}
public javax.net.ssl.SSLSession sslSession()
{
javax.net.ssl.SSLSession v;
io.vertx.core.http.WebSocketBase v;
io.vertx.mutiny.core.http.WebSocketBaseImpl v;
v := @this: io.vertx.mutiny.core.http.WebSocketBaseImpl;
v = v.<io.vertx.mutiny.core.http.WebSocketBaseImpl: io.vertx.core.http.WebSocketBase delegate>;
v = interfaceinvoke v.<io.vertx.core.http.WebSocketBase: javax.net.ssl.SSLSession sslSession()>();
return v;
}
}