public class io.smallrye.mutiny.vertx.AsyncResultUni extends io.smallrye.mutiny.operators.AbstractUni implements io.smallrye.mutiny.Uni
{
private final java.util.function.Consumer subscriptionConsumer;
public static io.smallrye.mutiny.Uni toUni(java.util.function.Consumer)
{
java.util.function.Consumer v;
io.smallrye.mutiny.vertx.AsyncResultUni v;
v := @parameter: java.util.function.Consumer;
v = new io.smallrye.mutiny.vertx.AsyncResultUni;
specialinvoke v.<io.smallrye.mutiny.vertx.AsyncResultUni: void <init>(java.util.function.Consumer)>(v);
return v;
}
public void <init>(java.util.function.Consumer)
{
java.util.function.Consumer v, v;
io.smallrye.mutiny.vertx.AsyncResultUni v;
v := @this: io.smallrye.mutiny.vertx.AsyncResultUni;
v := @parameter: java.util.function.Consumer;
specialinvoke v.<io.smallrye.mutiny.operators.AbstractUni: void <init>()>();
v = staticinvoke <io.smallrye.mutiny.infrastructure.Infrastructure: java.util.function.Consumer decorate(java.util.function.Consumer)>(v);
v.<io.smallrye.mutiny.vertx.AsyncResultUni: java.util.function.Consumer subscriptionConsumer> = v;
return;
}
public void subscribe(io.smallrye.mutiny.subscription.UniSubscriber)
{
io.smallrye.mutiny.subscription.UniSubscription v;
java.util.concurrent.atomic.AtomicBoolean v;
io.smallrye.mutiny.subscription.UniSubscriber v;
java.lang.Exception v;
java.util.function.Consumer v;
io.vertx.core.Handler v;
boolean v, v;
io.smallrye.mutiny.vertx.AsyncResultUni v;
v := @this: io.smallrye.mutiny.vertx.AsyncResultUni;
v := @parameter: io.smallrye.mutiny.subscription.UniSubscriber;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>()>();
v = staticinvoke <io.smallrye.mutiny.vertx.AsyncResultUni$lambda_subscribe_0__2314: io.smallrye.mutiny.subscription.UniSubscription bootstrap$(java.util.concurrent.atomic.AtomicBoolean)>(v);
interfaceinvoke v.<io.smallrye.mutiny.subscription.UniSubscriber: void onSubscribe(io.smallrye.mutiny.subscription.UniSubscription)>(v);
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
if v != 0 goto label;
label:
v = v.<io.smallrye.mutiny.vertx.AsyncResultUni: java.util.function.Consumer subscriptionConsumer>;
v = staticinvoke <io.smallrye.mutiny.vertx.AsyncResultUni$lambda_subscribe_1__2315: io.vertx.core.Handler bootstrap$(java.util.concurrent.atomic.AtomicBoolean,io.smallrye.mutiny.subscription.UniSubscriber)>(v, v);
interfaceinvoke v.<java.util.function.Consumer: void accept(java.lang.Object)>(v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean getAndSet(boolean)>(1);
if v != 0 goto label;
interfaceinvoke v.<io.smallrye.mutiny.subscription.UniSubscriber: void onFailure(java.lang.Throwable)>(v);
label:
return;
catch java.lang.Exception from label to label with label;
}
}