public final class io.smallrye.mutiny.operators.multi.MultiZipOp extends io.smallrye.mutiny.operators.AbstractMulti
{
private final java.util.List upstreams;
private final java.util.function.Function combinator;
private final int bufferSize;
private final boolean collectFailures;
public void <init>(java.lang.Iterable, java.util.function.Function, int, boolean)
{
java.util.function.Function v;
java.lang.Iterable v;
io.smallrye.mutiny.operators.multi.MultiZipOp v;
java.util.function.Consumer v;
java.util.List v;
int v;
java.util.LinkedList v;
boolean v;
v := @this: io.smallrye.mutiny.operators.multi.MultiZipOp;
v := @parameter: java.lang.Iterable;
v := @parameter: java.util.function.Function;
v := @parameter: int;
v := @parameter: boolean;
specialinvoke v.<io.smallrye.mutiny.operators.AbstractMulti: void <init>()>();
v = new java.util.LinkedList;
specialinvoke v.<java.util.LinkedList: void <init>()>();
v.<io.smallrye.mutiny.operators.multi.MultiZipOp: java.util.List upstreams> = v;
v = v.<io.smallrye.mutiny.operators.multi.MultiZipOp: java.util.List upstreams>;
virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <io.smallrye.mutiny.operators.multi.MultiZipOp$add__3212: java.util.function.Consumer bootstrap$(java.util.List)>(v);
interfaceinvoke v.<java.lang.Iterable: void forEach(java.util.function.Consumer)>(v);
v.<io.smallrye.mutiny.operators.multi.MultiZipOp: java.util.function.Function combinator> = v;
v.<io.smallrye.mutiny.operators.multi.MultiZipOp: int bufferSize> = v;
v.<io.smallrye.mutiny.operators.multi.MultiZipOp: boolean collectFailures> = v;
return;
}
public void subscribe(io.smallrye.mutiny.subscription.MultiSubscriber)
{
io.smallrye.mutiny.operators.multi.MultiZipOp$ZipCoordinator v;
java.util.function.Function v;
io.smallrye.mutiny.operators.multi.MultiZipOp v;
java.util.List v, v, v;
int v, v, v;
io.smallrye.mutiny.subscription.MultiSubscriber v;
boolean v;
v := @this: io.smallrye.mutiny.operators.multi.MultiZipOp;
v := @parameter: io.smallrye.mutiny.subscription.MultiSubscriber;
v = v.<io.smallrye.mutiny.operators.multi.MultiZipOp: java.util.List upstreams>;
v = interfaceinvoke v.<java.util.List: int size()>();
if v != 0 goto label;
staticinvoke <io.smallrye.mutiny.helpers.Subscriptions: void complete(java.util.concurrent.Flow$Subscriber)>(v);
return;
label:
v = new io.smallrye.mutiny.operators.multi.MultiZipOp$ZipCoordinator;
v = v.<io.smallrye.mutiny.operators.multi.MultiZipOp: java.util.function.Function combinator>;
v = v.<io.smallrye.mutiny.operators.multi.MultiZipOp: java.util.List upstreams>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v.<io.smallrye.mutiny.operators.multi.MultiZipOp: int bufferSize>;
v = v.<io.smallrye.mutiny.operators.multi.MultiZipOp: boolean collectFailures>;
specialinvoke v.<io.smallrye.mutiny.operators.multi.MultiZipOp$ZipCoordinator: void <init>(io.smallrye.mutiny.subscription.MultiSubscriber,java.util.function.Function,int,int,boolean)>(v, v, v, v, v);
interfaceinvoke v.<io.smallrye.mutiny.subscription.MultiSubscriber: void onSubscribe(java.util.concurrent.Flow$Subscription)>(v);
v = v.<io.smallrye.mutiny.operators.multi.MultiZipOp: java.util.List upstreams>;
virtualinvoke v.<io.smallrye.mutiny.operators.multi.MultiZipOp$ZipCoordinator: void subscribe(java.util.List)>(v);
return;
}
}