class io.smallrye.mutiny.operators.multi.MultiOnCancellationInvoke$MultiOnCancellationInvokeProcessor extends io.smallrye.mutiny.operators.multi.MultiOperatorProcessor
{
private final java.util.concurrent.atomic.AtomicBoolean actionInvoked;
final io.smallrye.mutiny.operators.multi.MultiOnCancellationInvoke this$0;
public void <init>(io.smallrye.mutiny.operators.multi.MultiOnCancellationInvoke, io.smallrye.mutiny.subscription.MultiSubscriber)
{
io.smallrye.mutiny.operators.multi.MultiOnCancellationInvoke v;
io.smallrye.mutiny.operators.multi.MultiOnCancellationInvoke$MultiOnCancellationInvokeProcessor v;
java.util.concurrent.atomic.AtomicBoolean v;
io.smallrye.mutiny.subscription.MultiSubscriber v;
v := @this: io.smallrye.mutiny.operators.multi.MultiOnCancellationInvoke$MultiOnCancellationInvokeProcessor;
v := @parameter: io.smallrye.mutiny.operators.multi.MultiOnCancellationInvoke;
v := @parameter: io.smallrye.mutiny.subscription.MultiSubscriber;
v.<io.smallrye.mutiny.operators.multi.MultiOnCancellationInvoke$MultiOnCancellationInvokeProcessor: io.smallrye.mutiny.operators.multi.MultiOnCancellationInvoke this$0> = v;
specialinvoke v.<io.smallrye.mutiny.operators.multi.MultiOperatorProcessor: void <init>(io.smallrye.mutiny.subscription.MultiSubscriber)>(v);
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>()>();
v.<io.smallrye.mutiny.operators.multi.MultiOnCancellationInvoke$MultiOnCancellationInvokeProcessor: java.util.concurrent.atomic.AtomicBoolean actionInvoked> = v;
return;
}
public void onCompletion()
{
java.util.concurrent.atomic.AtomicBoolean v;
io.smallrye.mutiny.operators.multi.MultiOnCancellationInvoke$MultiOnCancellationInvokeProcessor v;
v := @this: io.smallrye.mutiny.operators.multi.MultiOnCancellationInvoke$MultiOnCancellationInvokeProcessor;
v = v.<io.smallrye.mutiny.operators.multi.MultiOnCancellationInvoke$MultiOnCancellationInvokeProcessor: java.util.concurrent.atomic.AtomicBoolean actionInvoked>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(1);
specialinvoke v.<io.smallrye.mutiny.operators.multi.MultiOperatorProcessor: void onCompletion()>();
return;
}
public void cancel()
{
io.smallrye.mutiny.operators.multi.MultiOnCancellationInvoke v;
java.lang.Throwable v;
io.smallrye.mutiny.operators.multi.MultiOnCancellationInvoke$MultiOnCancellationInvokeProcessor v;
java.util.concurrent.atomic.AtomicBoolean v;
java.lang.Runnable v;
boolean v;
v := @this: io.smallrye.mutiny.operators.multi.MultiOnCancellationInvoke$MultiOnCancellationInvokeProcessor;
v = v.<io.smallrye.mutiny.operators.multi.MultiOnCancellationInvoke$MultiOnCancellationInvokeProcessor: java.util.concurrent.atomic.AtomicBoolean actionInvoked>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean compareAndSet(boolean,boolean)>(0, 1);
if v == 0 goto label;
label:
v = v.<io.smallrye.mutiny.operators.multi.MultiOnCancellationInvoke$MultiOnCancellationInvokeProcessor: io.smallrye.mutiny.operators.multi.MultiOnCancellationInvoke this$0>;
v = v.<io.smallrye.mutiny.operators.multi.MultiOnCancellationInvoke: java.lang.Runnable action>;
interfaceinvoke v.<java.lang.Runnable: void run()>();
label:
goto label;
label:
v := @caughtexception;
staticinvoke <io.smallrye.mutiny.infrastructure.Infrastructure: void handleDroppedException(java.lang.Throwable)>(v);
label:
specialinvoke v.<io.smallrye.mutiny.operators.multi.MultiOperatorProcessor: void cancel()>();
return;
catch java.lang.Throwable from label to label with label;
}
}