public class io.smallrye.mutiny.operators.multi.multicast.MultiConnectAfter extends io.smallrye.mutiny.operators.MultiOperator
{
private final int numberOfSubscribers;
private final java.util.concurrent.atomic.AtomicInteger count;
private final io.smallrye.mutiny.operators.multi.multicast.ConnectableMultiConnection connection;
public void <init>(io.smallrye.mutiny.operators.multi.multicast.ConnectableMulti, int, io.smallrye.mutiny.operators.multi.multicast.ConnectableMultiConnection)
{
io.smallrye.mutiny.operators.multi.multicast.MultiConnectAfter v;
io.smallrye.mutiny.operators.multi.multicast.ConnectableMulti v;
java.util.concurrent.atomic.AtomicInteger v;
int v;
io.smallrye.mutiny.operators.multi.multicast.ConnectableMultiConnection v;
v := @this: io.smallrye.mutiny.operators.multi.multicast.MultiConnectAfter;
v := @parameter: io.smallrye.mutiny.operators.multi.multicast.ConnectableMulti;
v := @parameter: int;
v := @parameter: io.smallrye.mutiny.operators.multi.multicast.ConnectableMultiConnection;
specialinvoke v.<io.smallrye.mutiny.operators.MultiOperator: void <init>(io.smallrye.mutiny.Multi)>(v);
v = new java.util.concurrent.atomic.AtomicInteger;
specialinvoke v.<java.util.concurrent.atomic.AtomicInteger: void <init>()>();
v.<io.smallrye.mutiny.operators.multi.multicast.MultiConnectAfter: java.util.concurrent.atomic.AtomicInteger count> = v;
v.<io.smallrye.mutiny.operators.multi.multicast.MultiConnectAfter: int numberOfSubscribers> = v;
v.<io.smallrye.mutiny.operators.multi.multicast.MultiConnectAfter: io.smallrye.mutiny.operators.multi.multicast.ConnectableMultiConnection connection> = v;
return;
}
public void subscribe(io.smallrye.mutiny.subscription.MultiSubscriber)
{
io.smallrye.mutiny.groups.MultiSubscribe v;
io.smallrye.mutiny.operators.multi.multicast.MultiConnectAfter v;
io.smallrye.mutiny.Multi v, v;
java.lang.NullPointerException v;
java.util.concurrent.atomic.AtomicInteger v;
int v, v;
io.smallrye.mutiny.operators.multi.multicast.ConnectableMultiConnection v;
io.smallrye.mutiny.subscription.MultiSubscriber v;
v := @this: io.smallrye.mutiny.operators.multi.multicast.MultiConnectAfter;
v := @parameter: io.smallrye.mutiny.subscription.MultiSubscriber;
if v != null goto label;
v = new java.lang.NullPointerException;
specialinvoke v.<java.lang.NullPointerException: void <init>(java.lang.String)>("The subscriber must not be `null`");
throw v;
label:
v = virtualinvoke v.<io.smallrye.mutiny.operators.multi.multicast.MultiConnectAfter: io.smallrye.mutiny.Multi upstream()>();
v = interfaceinvoke v.<io.smallrye.mutiny.Multi: io.smallrye.mutiny.groups.MultiSubscribe subscribe()>();
virtualinvoke v.<io.smallrye.mutiny.groups.MultiSubscribe: io.smallrye.mutiny.subscription.MultiSubscriber withSubscriber(io.smallrye.mutiny.subscription.MultiSubscriber)>(v);
v = v.<io.smallrye.mutiny.operators.multi.multicast.MultiConnectAfter: java.util.concurrent.atomic.AtomicInteger count>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int incrementAndGet()>();
v = v.<io.smallrye.mutiny.operators.multi.multicast.MultiConnectAfter: int numberOfSubscribers>;
if v != v goto label;
v = virtualinvoke v.<io.smallrye.mutiny.operators.multi.multicast.MultiConnectAfter: io.smallrye.mutiny.Multi upstream()>();
v = v.<io.smallrye.mutiny.operators.multi.multicast.MultiConnectAfter: io.smallrye.mutiny.operators.multi.multicast.ConnectableMultiConnection connection>;
virtualinvoke v.<io.smallrye.mutiny.operators.multi.multicast.ConnectableMulti: void connect(io.smallrye.mutiny.operators.multi.multicast.ConnectableMultiConnection)>(v);
label:
return;
}
}