public final class io.smallrye.mutiny.operators.multi.MultiRetryWhenOp extends io.smallrye.mutiny.operators.multi.AbstractMultiOperator
{
private final java.util.function.Function triggerStreamFactory;
private final java.util.function.Predicate onFailurePredicate;
public void <init>(io.smallrye.mutiny.Multi, java.util.function.Predicate, java.util.function.Function)
{
java.util.function.Predicate v;
io.smallrye.mutiny.operators.multi.MultiRetryWhenOp v;
java.util.function.Function v;
io.smallrye.mutiny.Multi v;
v := @this: io.smallrye.mutiny.operators.multi.MultiRetryWhenOp;
v := @parameter: io.smallrye.mutiny.Multi;
v := @parameter: java.util.function.Predicate;
v := @parameter: java.util.function.Function;
specialinvoke v.<io.smallrye.mutiny.operators.multi.AbstractMultiOperator: void <init>(io.smallrye.mutiny.Multi)>(v);
v.<io.smallrye.mutiny.operators.multi.MultiRetryWhenOp: java.util.function.Predicate onFailurePredicate> = v;
v.<io.smallrye.mutiny.operators.multi.MultiRetryWhenOp: java.util.function.Function triggerStreamFactory> = v;
return;
}
private static void subscribe(io.smallrye.mutiny.subscription.MultiSubscriber, java.util.function.Predicate, java.util.function.Function, io.smallrye.mutiny.Multi)
{
java.lang.Throwable v;
java.util.function.Predicate v;
io.smallrye.mutiny.subscription.SerializedSubscriber v, v;
java.util.function.Function v;
io.smallrye.mutiny.Multi v;
io.smallrye.mutiny.operators.multi.MultiRetryWhenOp$RetryWhenOperator v;
java.lang.NullPointerException v;
java.util.concurrent.Flow$Processor v;
io.smallrye.mutiny.operators.multi.MultiRetryWhenOp$TriggerSubscriber v;
java.lang.Object v;
io.smallrye.mutiny.subscription.MultiSubscriber v;
boolean v;
java.util.concurrent.Flow$Subscription v;
v := @parameter: io.smallrye.mutiny.subscription.MultiSubscriber;
v := @parameter: java.util.function.Predicate;
v := @parameter: java.util.function.Function;
v := @parameter: io.smallrye.mutiny.Multi;
v = new io.smallrye.mutiny.operators.multi.MultiRetryWhenOp$TriggerSubscriber;
specialinvoke v.<io.smallrye.mutiny.operators.multi.MultiRetryWhenOp$TriggerSubscriber: void <init>()>();
v = new io.smallrye.mutiny.subscription.SerializedSubscriber;
v = v.<io.smallrye.mutiny.operators.multi.MultiRetryWhenOp$TriggerSubscriber: java.util.concurrent.Flow$Processor processor>;
specialinvoke v.<io.smallrye.mutiny.subscription.SerializedSubscriber: void <init>(java.util.concurrent.Flow$Subscriber)>(v);
v = staticinvoke <io.smallrye.mutiny.helpers.Subscriptions: java.util.concurrent.Flow$Subscription empty()>();
interfaceinvoke v.<java.util.concurrent.Flow$Subscriber: void onSubscribe(java.util.concurrent.Flow$Subscription)>(v);
v = new io.smallrye.mutiny.subscription.SerializedSubscriber;
specialinvoke v.<io.smallrye.mutiny.subscription.SerializedSubscriber: void <init>(java.util.concurrent.Flow$Subscriber)>(v);
v = new io.smallrye.mutiny.operators.multi.MultiRetryWhenOp$RetryWhenOperator;
specialinvoke v.<io.smallrye.mutiny.operators.multi.MultiRetryWhenOp$RetryWhenOperator: void <init>(java.util.concurrent.Flow$Publisher,java.util.function.Predicate,io.smallrye.mutiny.subscription.MultiSubscriber,java.util.concurrent.Flow$Subscriber)>(v, v, v, v);
v.<io.smallrye.mutiny.operators.multi.MultiRetryWhenOp$TriggerSubscriber: io.smallrye.mutiny.operators.multi.MultiRetryWhenOp$RetryWhenOperator operator> = v;
interfaceinvoke v.<io.smallrye.mutiny.subscription.MultiSubscriber: void onSubscribe(java.util.concurrent.Flow$Subscription)>(v);
label:
v = interfaceinvoke v.<java.util.function.Function: java.lang.Object apply(java.lang.Object)>(v);
if v != null goto label;
v = new java.lang.NullPointerException;
specialinvoke v.<java.lang.NullPointerException: void <init>(java.lang.String)>("The stream factory returned `null`");
throw v;
label:
v := @caughtexception;
interfaceinvoke v.<io.smallrye.mutiny.subscription.MultiSubscriber: void onFailure(java.lang.Throwable)>(v);
return;
label:
interfaceinvoke v.<java.util.concurrent.Flow$Publisher: void subscribe(java.util.concurrent.Flow$Subscriber)>(v);
v = virtualinvoke v.<io.smallrye.mutiny.operators.multi.MultiRetryWhenOp$RetryWhenOperator: boolean isCancelled()>();
if v != 0 goto label;
interfaceinvoke v.<io.smallrye.mutiny.Multi: void subscribe(java.util.concurrent.Flow$Subscriber)>(v);
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void subscribe(io.smallrye.mutiny.subscription.MultiSubscriber)
{
java.util.function.Predicate v;
io.smallrye.mutiny.operators.multi.MultiRetryWhenOp v;
java.util.function.Function v;
io.smallrye.mutiny.Multi v;
io.smallrye.mutiny.subscription.MultiSubscriber v;
v := @this: io.smallrye.mutiny.operators.multi.MultiRetryWhenOp;
v := @parameter: io.smallrye.mutiny.subscription.MultiSubscriber;
v = v.<io.smallrye.mutiny.operators.multi.MultiRetryWhenOp: java.util.function.Predicate onFailurePredicate>;
v = v.<io.smallrye.mutiny.operators.multi.MultiRetryWhenOp: java.util.function.Function triggerStreamFactory>;
v = v.<io.smallrye.mutiny.operators.multi.MultiRetryWhenOp: io.smallrye.mutiny.Multi upstream>;
staticinvoke <io.smallrye.mutiny.operators.multi.MultiRetryWhenOp: void subscribe(io.smallrye.mutiny.subscription.MultiSubscriber,java.util.function.Predicate,java.util.function.Function,io.smallrye.mutiny.Multi)>(v, v, v, v);
return;
}
}