public class io.vertx.mutiny.core.net.NetClient extends java.lang.Object implements io.vertx.mutiny.core.metrics.Measured
{
public static final io.smallrye.mutiny.vertx.TypeArg __TYPE_ARG;
private final io.vertx.core.net.NetClient delegate;
public void <init>(io.vertx.core.net.NetClient)
{
io.vertx.mutiny.core.net.NetClient v;
io.vertx.core.net.NetClient v;
v := @this: io.vertx.mutiny.core.net.NetClient;
v := @parameter: io.vertx.core.net.NetClient;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<io.vertx.mutiny.core.net.NetClient: io.vertx.core.net.NetClient delegate> = v;
return;
}
public void <init>(java.lang.Object)
{
java.lang.Object v;
io.vertx.mutiny.core.net.NetClient v;
v := @this: io.vertx.mutiny.core.net.NetClient;
v := @parameter: java.lang.Object;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<io.vertx.mutiny.core.net.NetClient: io.vertx.core.net.NetClient delegate> = v;
return;
}
void <init>()
{
io.vertx.mutiny.core.net.NetClient v;
v := @this: io.vertx.mutiny.core.net.NetClient;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<io.vertx.mutiny.core.net.NetClient: io.vertx.core.net.NetClient delegate> = null;
return;
}
public io.vertx.core.net.NetClient getDelegate()
{
io.vertx.mutiny.core.net.NetClient v;
io.vertx.core.net.NetClient v;
v := @this: io.vertx.mutiny.core.net.NetClient;
v = v.<io.vertx.mutiny.core.net.NetClient: io.vertx.core.net.NetClient delegate>;
return v;
}
public java.lang.String toString()
{
io.vertx.mutiny.core.net.NetClient v;
java.lang.String v;
io.vertx.core.net.NetClient v;
v := @this: io.vertx.mutiny.core.net.NetClient;
v = v.<io.vertx.mutiny.core.net.NetClient: io.vertx.core.net.NetClient 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.NetClient v;
io.vertx.core.net.NetClient v, v;
boolean v;
v := @this: io.vertx.mutiny.core.net.NetClient;
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.NetClient: io.vertx.core.net.NetClient delegate>;
v = v.<io.vertx.mutiny.core.net.NetClient: io.vertx.core.net.NetClient 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.NetClient v;
io.vertx.core.net.NetClient v;
v := @this: io.vertx.mutiny.core.net.NetClient;
v = v.<io.vertx.mutiny.core.net.NetClient: io.vertx.core.net.NetClient delegate>;
v = virtualinvoke v.<java.lang.Object: int hashCode()>();
return v;
}
public boolean isMetricsEnabled()
{
io.vertx.mutiny.core.net.NetClient v;
io.vertx.core.net.NetClient v;
boolean v;
v := @this: io.vertx.mutiny.core.net.NetClient;
v = v.<io.vertx.mutiny.core.net.NetClient: io.vertx.core.net.NetClient delegate>;
v = interfaceinvoke v.<io.vertx.core.net.NetClient: boolean isMetricsEnabled()>();
return v;
}
public io.smallrye.mutiny.Uni connect(int, java.lang.String)
{
java.util.function.Consumer v;
int v;
io.vertx.mutiny.core.net.NetClient v;
java.lang.String v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetClient;
v := @parameter: int;
v := @parameter: java.lang.String;
v = staticinvoke <io.vertx.mutiny.core.net.NetClient$lambda_connect_3__1828: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.net.NetClient,int,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 io.vertx.mutiny.core.net.NetSocket connectAndAwait(int, java.lang.String)
{
io.smallrye.mutiny.groups.UniAwait v;
int v;
java.lang.Object v;
io.vertx.mutiny.core.net.NetClient v;
java.lang.String v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetClient;
v := @parameter: int;
v := @parameter: java.lang.String;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetClient: io.smallrye.mutiny.Uni connect(int,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 io.vertx.mutiny.core.net.NetClient connectAndForget(int, java.lang.String)
{
java.util.function.Consumer v;
int v;
io.smallrye.mutiny.groups.UniSubscribe v;
io.vertx.mutiny.core.net.NetClient v;
java.lang.String v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetClient;
v := @parameter: int;
v := @parameter: java.lang.String;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetClient: io.smallrye.mutiny.Uni connect(int,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 v;
}
public io.smallrye.mutiny.Uni connect(int, java.lang.String, java.lang.String)
{
java.util.function.Consumer v;
int v;
io.vertx.mutiny.core.net.NetClient v;
java.lang.String v, v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetClient;
v := @parameter: int;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = staticinvoke <io.vertx.mutiny.core.net.NetClient$lambda_connect_6__1829: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.net.NetClient,int,java.lang.String,java.lang.String)>(v, v, v, v);
v = staticinvoke <io.smallrye.mutiny.vertx.AsyncResultUni: io.smallrye.mutiny.Uni toUni(java.util.function.Consumer)>(v);
return v;
}
public io.vertx.mutiny.core.net.NetSocket connectAndAwait(int, java.lang.String, java.lang.String)
{
io.smallrye.mutiny.groups.UniAwait v;
int v;
java.lang.Object v;
io.vertx.mutiny.core.net.NetClient v;
java.lang.String v, v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetClient;
v := @parameter: int;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetClient: io.smallrye.mutiny.Uni connect(int,java.lang.String,java.lang.String)>(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.NetClient connectAndForget(int, java.lang.String, java.lang.String)
{
java.util.function.Consumer v;
int v;
io.smallrye.mutiny.groups.UniSubscribe v;
io.vertx.mutiny.core.net.NetClient v;
java.lang.String v, v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetClient;
v := @parameter: int;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetClient: io.smallrye.mutiny.Uni connect(int,java.lang.String,java.lang.String)>(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.smallrye.mutiny.Uni connect(io.vertx.mutiny.core.net.SocketAddress)
{
java.util.function.Consumer v;
io.vertx.mutiny.core.net.SocketAddress v;
io.vertx.mutiny.core.net.NetClient v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetClient;
v := @parameter: io.vertx.mutiny.core.net.SocketAddress;
v = staticinvoke <io.vertx.mutiny.core.net.NetClient$lambda_connect_9__1830: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.net.NetClient,io.vertx.mutiny.core.net.SocketAddress)>(v, v);
v = staticinvoke <io.smallrye.mutiny.vertx.AsyncResultUni: io.smallrye.mutiny.Uni toUni(java.util.function.Consumer)>(v);
return v;
}
public io.vertx.mutiny.core.net.NetSocket connectAndAwait(io.vertx.mutiny.core.net.SocketAddress)
{
io.smallrye.mutiny.groups.UniAwait v;
io.vertx.mutiny.core.net.SocketAddress v;
java.lang.Object v;
io.vertx.mutiny.core.net.NetClient v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetClient;
v := @parameter: io.vertx.mutiny.core.net.SocketAddress;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetClient: io.smallrye.mutiny.Uni connect(io.vertx.mutiny.core.net.SocketAddress)>(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.NetClient connectAndForget(io.vertx.mutiny.core.net.SocketAddress)
{
java.util.function.Consumer v;
io.vertx.mutiny.core.net.SocketAddress v;
io.smallrye.mutiny.groups.UniSubscribe v;
io.vertx.mutiny.core.net.NetClient v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetClient;
v := @parameter: io.vertx.mutiny.core.net.SocketAddress;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetClient: io.smallrye.mutiny.Uni connect(io.vertx.mutiny.core.net.SocketAddress)>(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 connect(io.vertx.mutiny.core.net.SocketAddress, java.lang.String)
{
java.util.function.Consumer v;
io.vertx.mutiny.core.net.SocketAddress v;
io.vertx.mutiny.core.net.NetClient v;
java.lang.String v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetClient;
v := @parameter: io.vertx.mutiny.core.net.SocketAddress;
v := @parameter: java.lang.String;
v = staticinvoke <io.vertx.mutiny.core.net.NetClient$lambda_connect_12__1831: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.net.NetClient,io.vertx.mutiny.core.net.SocketAddress,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 io.vertx.mutiny.core.net.NetSocket connectAndAwait(io.vertx.mutiny.core.net.SocketAddress, java.lang.String)
{
io.smallrye.mutiny.groups.UniAwait v;
io.vertx.mutiny.core.net.SocketAddress v;
java.lang.Object v;
io.vertx.mutiny.core.net.NetClient v;
java.lang.String v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetClient;
v := @parameter: io.vertx.mutiny.core.net.SocketAddress;
v := @parameter: java.lang.String;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetClient: io.smallrye.mutiny.Uni connect(io.vertx.mutiny.core.net.SocketAddress,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 io.vertx.mutiny.core.net.NetClient connectAndForget(io.vertx.mutiny.core.net.SocketAddress, java.lang.String)
{
java.util.function.Consumer v;
io.vertx.mutiny.core.net.SocketAddress v;
io.smallrye.mutiny.groups.UniSubscribe v;
io.vertx.mutiny.core.net.NetClient v;
java.lang.String v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetClient;
v := @parameter: io.vertx.mutiny.core.net.SocketAddress;
v := @parameter: java.lang.String;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetClient: io.smallrye.mutiny.Uni connect(io.vertx.mutiny.core.net.SocketAddress,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 v;
}
public io.smallrye.mutiny.Uni close()
{
java.util.function.Consumer v;
io.vertx.mutiny.core.net.NetClient v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetClient;
v = staticinvoke <io.vertx.mutiny.core.net.NetClient$lambda_close_13__1832: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.net.NetClient)>(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.NetClient v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetClient;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetClient: 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.NetClient v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetClient;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetClient: 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 updateSSLOptions(io.vertx.core.net.SSLOptions)
{
java.util.function.Consumer v;
io.vertx.core.net.SSLOptions v;
io.vertx.mutiny.core.net.NetClient v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetClient;
v := @parameter: io.vertx.core.net.SSLOptions;
v = staticinvoke <io.vertx.mutiny.core.net.NetClient$lambda_updateSSLOptions_14__1833: java.util.function.Consumer bootstrap$(io.vertx.mutiny.core.net.NetClient,io.vertx.core.net.SSLOptions)>(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 updateSSLOptionsAndAwait(io.vertx.core.net.SSLOptions)
{
io.smallrye.mutiny.groups.UniAwait v;
io.vertx.core.net.SSLOptions v;
java.lang.Object v;
io.vertx.mutiny.core.net.NetClient v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetClient;
v := @parameter: io.vertx.core.net.SSLOptions;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetClient: io.smallrye.mutiny.Uni updateSSLOptions(io.vertx.core.net.SSLOptions)>(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 updateSSLOptionsAndForget(io.vertx.core.net.SSLOptions)
{
java.util.function.Consumer v;
io.vertx.core.net.SSLOptions v;
io.smallrye.mutiny.groups.UniSubscribe v;
io.vertx.mutiny.core.net.NetClient v;
io.smallrye.mutiny.Uni v;
v := @this: io.vertx.mutiny.core.net.NetClient;
v := @parameter: io.vertx.core.net.SSLOptions;
v = virtualinvoke v.<io.vertx.mutiny.core.net.NetClient: io.smallrye.mutiny.Uni updateSSLOptions(io.vertx.core.net.SSLOptions)>(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 static io.vertx.mutiny.core.net.NetClient newInstance(io.vertx.core.net.NetClient)
{
io.vertx.mutiny.core.net.NetClient v;
io.vertx.core.net.NetClient v;
v := @parameter: io.vertx.core.net.NetClient;
if v == null goto label;
v = new io.vertx.mutiny.core.net.NetClient;
specialinvoke v.<io.vertx.mutiny.core.net.NetClient: void <init>(io.vertx.core.net.NetClient)>(v);
goto label;
label:
v = null;
label:
return v;
}
static void <clinit>()
{
java.util.function.Function v, v;
io.smallrye.mutiny.vertx.TypeArg v;
v = new io.smallrye.mutiny.vertx.TypeArg;
v = staticinvoke <io.vertx.mutiny.core.net.NetClient$lambda_static_0__1842: java.util.function.Function bootstrap$()>();
v = staticinvoke <io.vertx.mutiny.core.net.NetClient$getDelegate__1843: 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.NetClient: io.smallrye.mutiny.vertx.TypeArg __TYPE_ARG> = v;
return;
}
}