public class io.vertx.mutiny.core.net.NetSocket extends java.lang.Object implements io.vertx.mutiny.core.streams.ReadStream, io.vertx.mutiny.core.streams.WriteStream
{
public static final io.smallrye.mutiny.vertx.TypeArg __TYPE_ARG;
private final io.vertx.core.net.NetSocket delegate;
static final io.smallrye.mutiny.vertx.TypeArg TYPE_ARG_0;
private io.smallrye.mutiny.vertx.WriteStreamSubscriber subscriber;
private io.vertx.mutiny.core.net.SocketAddress cached_0;
private io.vertx.mutiny.core.net.SocketAddress cached_1;
private io.smallrye.mutiny.Multi multi;
public void <init>(io.vertx.core.net.NetSocket)
{
io.vertx.mutiny.core.net.NetSocket v;
io.vertx.core.net.NetSocket v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: io.vertx.core.net.NetSocket;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.core.net.NetSocket delegate> = v;
return;
}
public void <init>(java.lang.Object)
{
java.lang.Object v;
io.vertx.mutiny.core.net.NetSocket v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: java.lang.Object;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.core.net.NetSocket delegate> = v;
return;
}
void <init>()
{
io.vertx.mutiny.core.net.NetSocket v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.core.net.NetSocket delegate> = null;
return;
}
public io.vertx.core.net.NetSocket getDelegate()
{
io.vertx.mutiny.core.net.NetSocket v;
io.vertx.core.net.NetSocket v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v = v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.core.net.NetSocket delegate>;
return v;
}
public java.lang.String toString()
{
java.lang.String v;
io.vertx.mutiny.core.net.NetSocket v;
io.vertx.core.net.NetSocket v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v = v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.core.net.NetSocket delegate>;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
return v;
}
public boolean equals(java.lang.Object)
{
java.lang.Class v, v;
java.lang.Object v;
io.vertx.mutiny.core.net.NetSocket v;
boolean v;
io.vertx.core.net.NetSocket v, v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: java.lang.Object;
if v != v goto label;
return 1;
label:
if v == null goto label;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
if v == v goto label;
label:
return 0;
label:
v = v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.core.net.NetSocket delegate>;
v = v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.core.net.NetSocket delegate>;
v = virtualinvoke v.<java.lang.Object: boolean equals(java.lang.Object)>(v);
return v;
}
public int hashCode()
{
int v;
io.vertx.mutiny.core.net.NetSocket v;
io.vertx.core.net.NetSocket v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v = v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.core.net.NetSocket delegate>;
v = virtualinvoke v.<java.lang.Object: int hashCode()>();
return v;
}
public synchronized io.smallrye.mutiny.vertx.WriteStreamSubscriber toSubscriber()
{
io.smallrye.mutiny.vertx.WriteStreamSubscriber v, v, v;
java.util.function.Function v;
io.vertx.mutiny.core.net.NetSocket v;
io.vertx.core.net.NetSocket v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v = v.<io.vertx.mutiny.core.net.NetSocket: io.smallrye.mutiny.vertx.WriteStreamSubscriber subscriber>;
if v != null goto label;
v = staticinvoke <io.vertx.mutiny.core.net.NetSocket$getDelegate__1844: java.util.function.Function bootstrap$()>();
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.core.net.NetSocket getDelegate()>();
v = staticinvoke <io.smallrye.mutiny.vertx.MutinyHelper: io.smallrye.mutiny.vertx.WriteStreamSubscriber toSubscriber(io.vertx.core.streams.WriteStream,java.util.function.Function)>(v, v);
v.<io.vertx.mutiny.core.net.NetSocket: io.smallrye.mutiny.vertx.WriteStreamSubscriber subscriber> = v;
label:
v = v.<io.vertx.mutiny.core.net.NetSocket: io.smallrye.mutiny.vertx.WriteStreamSubscriber subscriber>;
return v;
}
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.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: io.vertx.mutiny.core.buffer.Buffer;
v = staticinvoke <io.vertx.mutiny.core.net.NetSocket$lambda_end_3__1845: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.net.NetSocket,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.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: io.vertx.mutiny.core.buffer.Buffer;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetSocket: 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.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: io.vertx.mutiny.core.buffer.Buffer;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetSocket: 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.mutiny.core.net.NetSocket v;
boolean v;
io.vertx.core.net.NetSocket v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v = v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.core.net.NetSocket delegate>;
v = interfaceinvoke v.<io.vertx.core.net.NetSocket: 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.smallrye.mutiny.vertx.TypeArg v;
io.vertx.mutiny.core.net.NetSocket v;
io.vertx.core.net.NetSocket v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v = v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.core.net.NetSocket delegate>;
v = interfaceinvoke v.<io.vertx.core.net.NetSocket: io.vertx.core.streams.Pipe pipe()>();
v = <io.vertx.mutiny.core.net.NetSocket: 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.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: io.vertx.mutiny.core.streams.WriteStream;
v = staticinvoke <io.vertx.mutiny.core.net.NetSocket$lambda_pipeTo_4__1846: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.net.NetSocket,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.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: io.vertx.mutiny.core.streams.WriteStream;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetSocket: 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.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: io.vertx.mutiny.core.streams.WriteStream;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetSocket: 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.net.NetSocket __exceptionHandler(io.vertx.core.Handler)
{
io.vertx.core.Handler v;
io.vertx.mutiny.core.net.NetSocket v;
io.vertx.core.net.NetSocket v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: io.vertx.core.Handler;
v = v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.core.net.NetSocket delegate>;
interfaceinvoke v.<io.vertx.core.net.NetSocket: io.vertx.core.net.NetSocket exceptionHandler(io.vertx.core.Handler)>(v);
return v;
}
public io.vertx.mutiny.core.net.NetSocket exceptionHandler(java.util.function.Consumer)
{
java.util.function.Consumer v;
io.smallrye.mutiny.vertx.DelegatingConsumerHandler v;
io.vertx.mutiny.core.net.NetSocket v, v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
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.net.NetSocket: io.vertx.mutiny.core.net.NetSocket __exceptionHandler(io.vertx.core.Handler)>(v);
return v;
}
private io.vertx.mutiny.core.net.NetSocket __handler(io.vertx.core.Handler)
{
io.smallrye.mutiny.vertx.DelegatingHandler v;
io.vertx.core.Handler v;
java.util.function.Function v;
io.vertx.mutiny.core.net.NetSocket v;
io.vertx.core.net.NetSocket v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: io.vertx.core.Handler;
v = v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.core.net.NetSocket delegate>;
v = new io.smallrye.mutiny.vertx.DelegatingHandler;
v = staticinvoke <io.vertx.mutiny.core.net.NetSocket$lambda___handler_5__1847: 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.net.NetSocket: io.vertx.core.net.NetSocket handler(io.vertx.core.Handler)>(v);
return v;
}
public io.vertx.mutiny.core.net.NetSocket handler(java.util.function.Consumer)
{
java.util.function.Consumer v;
io.smallrye.mutiny.vertx.DelegatingConsumerHandler v;
io.vertx.mutiny.core.net.NetSocket v, v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
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.net.NetSocket: io.vertx.mutiny.core.net.NetSocket __handler(io.vertx.core.Handler)>(v);
return v;
}
public io.vertx.mutiny.core.net.NetSocket pause()
{
io.vertx.mutiny.core.net.NetSocket v;
io.vertx.core.net.NetSocket v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v = v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.core.net.NetSocket delegate>;
interfaceinvoke v.<io.vertx.core.net.NetSocket: io.vertx.core.net.NetSocket pause()>();
return v;
}
public io.vertx.mutiny.core.net.NetSocket resume()
{
io.vertx.mutiny.core.net.NetSocket v;
io.vertx.core.net.NetSocket v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v = v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.core.net.NetSocket delegate>;
interfaceinvoke v.<io.vertx.core.net.NetSocket: io.vertx.core.net.NetSocket resume()>();
return v;
}
public io.vertx.mutiny.core.net.NetSocket fetch(long)
{
long v;
io.vertx.mutiny.core.net.NetSocket v;
io.vertx.core.net.NetSocket v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: long;
v = v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.core.net.NetSocket delegate>;
interfaceinvoke v.<io.vertx.core.net.NetSocket: io.vertx.core.net.NetSocket fetch(long)>(v);
return v;
}
private io.vertx.mutiny.core.net.NetSocket __endHandler(io.vertx.core.Handler)
{
io.vertx.core.Handler v;
io.vertx.mutiny.core.net.NetSocket v;
io.vertx.core.net.NetSocket v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: io.vertx.core.Handler;
v = v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.core.net.NetSocket delegate>;
interfaceinvoke v.<io.vertx.core.net.NetSocket: io.vertx.core.net.NetSocket endHandler(io.vertx.core.Handler)>(v);
return v;
}
public io.vertx.mutiny.core.net.NetSocket endHandler(java.lang.Runnable)
{
io.vertx.core.Handler v;
java.lang.Runnable v;
io.vertx.mutiny.core.net.NetSocket v, v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: java.lang.Runnable;
v = staticinvoke <io.vertx.mutiny.core.net.NetSocket$lambda_endHandler_6__1848: io.vertx.core.Handler bootstrap$(java.lang.Runnable)>(v);
v = specialinvoke v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.mutiny.core.net.NetSocket __endHandler(io.vertx.core.Handler)>(v);
return v;
}
public io.vertx.mutiny.core.net.NetSocket setWriteQueueMaxSize(int)
{
int v;
io.vertx.mutiny.core.net.NetSocket v;
io.vertx.core.net.NetSocket v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: int;
v = v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.core.net.NetSocket delegate>;
interfaceinvoke v.<io.vertx.core.net.NetSocket: io.vertx.core.net.NetSocket setWriteQueueMaxSize(int)>(v);
return v;
}
private io.vertx.mutiny.core.net.NetSocket __drainHandler(io.vertx.core.Handler)
{
io.vertx.core.Handler v;
io.vertx.mutiny.core.net.NetSocket v;
io.vertx.core.net.NetSocket v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: io.vertx.core.Handler;
v = v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.core.net.NetSocket delegate>;
interfaceinvoke v.<io.vertx.core.net.NetSocket: io.vertx.core.net.NetSocket drainHandler(io.vertx.core.Handler)>(v);
return v;
}
public io.vertx.mutiny.core.net.NetSocket drainHandler(java.lang.Runnable)
{
io.vertx.core.Handler v;
java.lang.Runnable v;
io.vertx.mutiny.core.net.NetSocket v, v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: java.lang.Runnable;
v = staticinvoke <io.vertx.mutiny.core.net.NetSocket$lambda_drainHandler_7__1849: io.vertx.core.Handler bootstrap$(java.lang.Runnable)>(v);
v = specialinvoke v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.mutiny.core.net.NetSocket __drainHandler(io.vertx.core.Handler)>(v);
return v;
}
public java.lang.String writeHandlerID()
{
java.lang.String v;
io.vertx.mutiny.core.net.NetSocket v;
io.vertx.core.net.NetSocket v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v = v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.core.net.NetSocket delegate>;
v = interfaceinvoke v.<io.vertx.core.net.NetSocket: java.lang.String writeHandlerID()>();
return v;
}
public io.smallrye.mutiny.Uni write(java.lang.String)
{
java.util.function.Consumer v;
java.lang.String v;
io.vertx.mutiny.core.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: java.lang.String;
v = staticinvoke <io.vertx.mutiny.core.net.NetSocket$lambda_write_8__1850: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.net.NetSocket,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 writeAndAwait(java.lang.String)
{
io.smallrye.mutiny.groups.UniAwait v;
java.lang.Object v;
java.lang.String v;
io.vertx.mutiny.core.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: java.lang.String;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetSocket: io.smallrye.mutiny.Uni write(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 void writeAndForget(java.lang.String)
{
java.util.function.Consumer v;
io.smallrye.mutiny.groups.UniSubscribe v;
java.lang.String v;
io.vertx.mutiny.core.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: java.lang.String;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetSocket: io.smallrye.mutiny.Uni write(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;
}
public io.smallrye.mutiny.Uni write(java.lang.String, java.lang.String)
{
java.util.function.Consumer v;
java.lang.String v, v;
io.vertx.mutiny.core.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = staticinvoke <io.vertx.mutiny.core.net.NetSocket$lambda_write_9__1851: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.net.NetSocket,java.lang.String,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 writeAndAwait(java.lang.String, java.lang.String)
{
io.smallrye.mutiny.groups.UniAwait v;
java.lang.Object v;
java.lang.String v, v;
io.vertx.mutiny.core.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetSocket: io.smallrye.mutiny.Uni write(java.lang.String,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 writeAndForget(java.lang.String, java.lang.String)
{
java.util.function.Consumer v;
io.smallrye.mutiny.groups.UniSubscribe v;
java.lang.String v, v;
io.vertx.mutiny.core.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetSocket: io.smallrye.mutiny.Uni write(java.lang.String,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.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.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: io.vertx.mutiny.core.buffer.Buffer;
v = staticinvoke <io.vertx.mutiny.core.net.NetSocket$lambda_write_10__1852: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.net.NetSocket,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.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: io.vertx.mutiny.core.buffer.Buffer;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetSocket: 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.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: io.vertx.mutiny.core.buffer.Buffer;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetSocket: 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 sendFile(java.lang.String)
{
java.util.function.Consumer v;
java.lang.String v;
io.vertx.mutiny.core.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: java.lang.String;
v = staticinvoke <io.vertx.mutiny.core.net.NetSocket$lambda_sendFile_11__1853: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.net.NetSocket,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 sendFileAndAwait(java.lang.String)
{
io.smallrye.mutiny.groups.UniAwait v;
java.lang.Object v;
java.lang.String v;
io.vertx.mutiny.core.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: java.lang.String;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetSocket: io.smallrye.mutiny.Uni sendFile(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.net.NetSocket sendFileAndForget(java.lang.String)
{
java.util.function.Consumer v;
io.smallrye.mutiny.groups.UniSubscribe v;
java.lang.String v;
io.vertx.mutiny.core.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: java.lang.String;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetSocket: io.smallrye.mutiny.Uni sendFile(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 sendFile(java.lang.String, long)
{
java.util.function.Consumer v;
long v;
java.lang.String v;
io.vertx.mutiny.core.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: java.lang.String;
v := @parameter: long;
v = staticinvoke <io.vertx.mutiny.core.net.NetSocket$lambda_sendFile_12__1854: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.net.NetSocket,java.lang.String,long)>(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 sendFileAndAwait(java.lang.String, long)
{
io.smallrye.mutiny.groups.UniAwait v;
java.lang.Object v;
long v;
java.lang.String v;
io.vertx.mutiny.core.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: java.lang.String;
v := @parameter: long;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetSocket: io.smallrye.mutiny.Uni sendFile(java.lang.String,long)>(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 io.vertx.mutiny.core.net.NetSocket sendFileAndForget(java.lang.String, long)
{
java.util.function.Consumer v;
io.smallrye.mutiny.groups.UniSubscribe v;
long v;
java.lang.String v;
io.vertx.mutiny.core.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: java.lang.String;
v := @parameter: long;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetSocket: io.smallrye.mutiny.Uni sendFile(java.lang.String,long)>(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 v;
}
public io.smallrye.mutiny.Uni sendFile(java.lang.String, long, long)
{
java.util.function.Consumer v;
long v, v;
java.lang.String v;
io.vertx.mutiny.core.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: java.lang.String;
v := @parameter: long;
v := @parameter: long;
v = staticinvoke <io.vertx.mutiny.core.net.NetSocket$lambda_sendFile_13__1855: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.net.NetSocket,java.lang.String,long,long)>(v, 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 sendFileAndAwait(java.lang.String, long, long)
{
io.smallrye.mutiny.groups.UniAwait v;
java.lang.Object v;
long v, v;
java.lang.String v;
io.vertx.mutiny.core.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: java.lang.String;
v := @parameter: long;
v := @parameter: long;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetSocket: io.smallrye.mutiny.Uni sendFile(java.lang.String,long,long)>(v, 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 io.vertx.mutiny.core.net.NetSocket sendFileAndForget(java.lang.String, long, long)
{
java.util.function.Consumer v;
io.smallrye.mutiny.groups.UniSubscribe v;
long v, v;
java.lang.String v;
io.vertx.mutiny.core.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: java.lang.String;
v := @parameter: long;
v := @parameter: long;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetSocket: io.smallrye.mutiny.Uni sendFile(java.lang.String,long,long)>(v, 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 v;
}
public io.vertx.mutiny.core.net.SocketAddress remoteAddress()
{
io.vertx.mutiny.core.net.SocketAddress v, v, v;
io.vertx.mutiny.core.net.NetSocket v;
io.vertx.core.net.NetSocket v;
io.vertx.core.net.SocketAddress v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v = v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.mutiny.core.net.SocketAddress cached_0>;
if v == null goto label;
v = v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.mutiny.core.net.SocketAddress cached_0>;
return v;
label:
v = v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.core.net.NetSocket delegate>;
v = interfaceinvoke v.<io.vertx.core.net.NetSocket: 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.net.NetSocket: io.vertx.mutiny.core.net.SocketAddress cached_0> = v;
return v;
}
public io.vertx.mutiny.core.net.SocketAddress remoteAddress(boolean)
{
io.vertx.mutiny.core.net.SocketAddress v;
io.vertx.mutiny.core.net.NetSocket v;
boolean v;
io.vertx.core.net.NetSocket v;
io.vertx.core.net.SocketAddress v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: boolean;
v = v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.core.net.NetSocket delegate>;
v = interfaceinvoke v.<io.vertx.core.net.NetSocket: io.vertx.core.net.SocketAddress remoteAddress(boolean)>(v);
v = staticinvoke <io.vertx.mutiny.core.net.SocketAddress: io.vertx.mutiny.core.net.SocketAddress newInstance(io.vertx.core.net.SocketAddress)>(v);
return v;
}
public io.vertx.mutiny.core.net.SocketAddress localAddress()
{
io.vertx.mutiny.core.net.SocketAddress v, v, v;
io.vertx.mutiny.core.net.NetSocket v;
io.vertx.core.net.NetSocket v;
io.vertx.core.net.SocketAddress v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v = v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.mutiny.core.net.SocketAddress cached_1>;
if v == null goto label;
v = v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.mutiny.core.net.SocketAddress cached_1>;
return v;
label:
v = v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.core.net.NetSocket delegate>;
v = interfaceinvoke v.<io.vertx.core.net.NetSocket: 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.net.NetSocket: io.vertx.mutiny.core.net.SocketAddress cached_1> = v;
return v;
}
public io.vertx.mutiny.core.net.SocketAddress localAddress(boolean)
{
io.vertx.mutiny.core.net.SocketAddress v;
io.vertx.mutiny.core.net.NetSocket v;
boolean v;
io.vertx.core.net.NetSocket v;
io.vertx.core.net.SocketAddress v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: boolean;
v = v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.core.net.NetSocket delegate>;
v = interfaceinvoke v.<io.vertx.core.net.NetSocket: io.vertx.core.net.SocketAddress localAddress(boolean)>(v);
v = staticinvoke <io.vertx.mutiny.core.net.SocketAddress: io.vertx.mutiny.core.net.SocketAddress newInstance(io.vertx.core.net.SocketAddress)>(v);
return v;
}
public io.smallrye.mutiny.Uni end()
{
java.util.function.Consumer v;
io.vertx.mutiny.core.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v = staticinvoke <io.vertx.mutiny.core.net.NetSocket$lambda_end_14__1856: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.net.NetSocket)>(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.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetSocket: 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.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetSocket: 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.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v = staticinvoke <io.vertx.mutiny.core.net.NetSocket$lambda_close_15__1857: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.net.NetSocket)>(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.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetSocket: 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.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetSocket: 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;
}
private io.vertx.mutiny.core.net.NetSocket __closeHandler(io.vertx.core.Handler)
{
io.vertx.core.Handler v;
io.vertx.mutiny.core.net.NetSocket v;
io.vertx.core.net.NetSocket v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: io.vertx.core.Handler;
v = v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.core.net.NetSocket delegate>;
interfaceinvoke v.<io.vertx.core.net.NetSocket: io.vertx.core.net.NetSocket closeHandler(io.vertx.core.Handler)>(v);
return v;
}
public io.vertx.mutiny.core.net.NetSocket closeHandler(java.lang.Runnable)
{
io.vertx.core.Handler v;
java.lang.Runnable v;
io.vertx.mutiny.core.net.NetSocket v, v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: java.lang.Runnable;
v = staticinvoke <io.vertx.mutiny.core.net.NetSocket$lambda_closeHandler_16__1858: io.vertx.core.Handler bootstrap$(java.lang.Runnable)>(v);
v = specialinvoke v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.mutiny.core.net.NetSocket __closeHandler(io.vertx.core.Handler)>(v);
return v;
}
public io.smallrye.mutiny.Uni upgradeToSsl()
{
java.util.function.Consumer v;
io.vertx.mutiny.core.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v = staticinvoke <io.vertx.mutiny.core.net.NetSocket$lambda_upgradeToSsl_17__1859: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.net.NetSocket)>(v);
v = staticinvoke <io.smallrye.mutiny.vertx.AsyncResultUni: io.smallrye.mutiny.Uni toUni(java.util.function.Consumer)>(v);
return v;
}
public java.lang.Void upgradeToSslAndAwait()
{
io.smallrye.mutiny.groups.UniAwait v;
java.lang.Object v;
io.vertx.mutiny.core.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetSocket: io.smallrye.mutiny.Uni upgradeToSsl()>();
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.net.NetSocket upgradeToSslAndForget()
{
java.util.function.Consumer v;
io.smallrye.mutiny.groups.UniSubscribe v;
io.vertx.mutiny.core.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetSocket: io.smallrye.mutiny.Uni upgradeToSsl()>();
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 upgradeToSsl(java.lang.String)
{
java.util.function.Consumer v;
java.lang.String v;
io.vertx.mutiny.core.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: java.lang.String;
v = staticinvoke <io.vertx.mutiny.core.net.NetSocket$lambda_upgradeToSsl_18__1860: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.net.NetSocket,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 upgradeToSslAndAwait(java.lang.String)
{
io.smallrye.mutiny.groups.UniAwait v;
java.lang.Object v;
java.lang.String v;
io.vertx.mutiny.core.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: java.lang.String;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetSocket: io.smallrye.mutiny.Uni upgradeToSsl(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.net.NetSocket upgradeToSslAndForget(java.lang.String)
{
java.util.function.Consumer v;
io.smallrye.mutiny.groups.UniSubscribe v;
java.lang.String v;
io.vertx.mutiny.core.net.NetSocket v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v := @parameter: java.lang.String;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetSocket: io.smallrye.mutiny.Uni upgradeToSsl(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 boolean isSsl()
{
io.vertx.mutiny.core.net.NetSocket v;
boolean v;
io.vertx.core.net.NetSocket v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v = v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.core.net.NetSocket delegate>;
v = interfaceinvoke v.<io.vertx.core.net.NetSocket: boolean isSsl()>();
return v;
}
public java.lang.String indicatedServerName()
{
java.lang.String v;
io.vertx.mutiny.core.net.NetSocket v;
io.vertx.core.net.NetSocket v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v = v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.core.net.NetSocket delegate>;
v = interfaceinvoke v.<io.vertx.core.net.NetSocket: java.lang.String indicatedServerName()>();
return v;
}
public java.lang.String applicationLayerProtocol()
{
java.lang.String v;
io.vertx.mutiny.core.net.NetSocket v;
io.vertx.core.net.NetSocket v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v = v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.core.net.NetSocket delegate>;
v = interfaceinvoke v.<io.vertx.core.net.NetSocket: java.lang.String applicationLayerProtocol()>();
return v;
}
public javax.net.ssl.SSLSession sslSession()
{
javax.net.ssl.SSLSession v;
io.vertx.mutiny.core.net.NetSocket v;
io.vertx.core.net.NetSocket v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v = v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.core.net.NetSocket delegate>;
v = interfaceinvoke v.<io.vertx.core.net.NetSocket: javax.net.ssl.SSLSession sslSession()>();
return v;
}
public synchronized io.smallrye.mutiny.Multi toMulti()
{
java.util.function.Function v;
io.smallrye.mutiny.Multi v, v, v;
io.vertx.mutiny.core.net.NetSocket v;
io.vertx.core.net.NetSocket v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v = v.<io.vertx.mutiny.core.net.NetSocket: io.smallrye.mutiny.Multi multi>;
if v != null goto label;
v = staticinvoke <io.vertx.mutiny.core.net.NetSocket$newInstance__1861: java.util.function.Function bootstrap$()>();
v = v.<io.vertx.mutiny.core.net.NetSocket: io.vertx.core.net.NetSocket 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.net.NetSocket: io.smallrye.mutiny.Multi multi> = v;
label:
v = v.<io.vertx.mutiny.core.net.NetSocket: 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.smallrye.mutiny.Multi v;
io.vertx.mutiny.core.net.NetSocket v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetSocket: 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.smallrye.mutiny.Multi v;
io.vertx.mutiny.core.net.NetSocket v;
v := @this: io.vertx.mutiny.core.net.NetSocket;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetSocket: 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 static io.vertx.mutiny.core.net.NetSocket newInstance(io.vertx.core.net.NetSocket)
{
io.vertx.mutiny.core.net.NetSocket v;
io.vertx.core.net.NetSocket v;
v := @parameter: io.vertx.core.net.NetSocket;
if v == null goto label;
v = new io.vertx.mutiny.core.net.NetSocket;
specialinvoke v.<io.vertx.mutiny.core.net.NetSocket: void <init>(io.vertx.core.net.NetSocket)>(v);
goto label;
label:
v = null;
label:
return v;
}
static void <clinit>()
{
io.smallrye.mutiny.vertx.TypeArg v, v;
java.util.function.Function v, v, v, v;
v = new io.smallrye.mutiny.vertx.TypeArg;
v = staticinvoke <io.vertx.mutiny.core.net.NetSocket$lambda_static_0__1862: java.util.function.Function bootstrap$()>();
v = staticinvoke <io.vertx.mutiny.core.net.NetSocket$getDelegate__1863: java.util.function.Function bootstrap$()>();
specialinvoke v.<io.smallrye.mutiny.vertx.TypeArg: void <init>(java.util.function.Function,java.util.function.Function)>(v, v);
<io.vertx.mutiny.core.net.NetSocket: io.smallrye.mutiny.vertx.TypeArg __TYPE_ARG> = v;
v = new io.smallrye.mutiny.vertx.TypeArg;
v = staticinvoke <io.vertx.mutiny.core.net.NetSocket$lambda_static_1__1864: java.util.function.Function bootstrap$()>();
v = staticinvoke <io.vertx.mutiny.core.net.NetSocket$lambda_static_2__1865: java.util.function.Function bootstrap$()>();
specialinvoke v.<io.smallrye.mutiny.vertx.TypeArg: void <init>(java.util.function.Function,java.util.function.Function)>(v, v);
<io.vertx.mutiny.core.net.NetSocket: io.smallrye.mutiny.vertx.TypeArg TYPE_ARG_0> = v;
return;
}
}