class io.smallrye.mutiny.groups.MultiCreate$2 extends io.smallrye.mutiny.operators.AbstractMulti
{
final java.util.concurrent.Flow$Publisher val$actual;
final io.smallrye.mutiny.groups.MultiCreate this$0;
void <init>(io.smallrye.mutiny.groups.MultiCreate, java.util.concurrent.Flow$Publisher)
{
java.util.concurrent.Flow$Publisher v;
io.smallrye.mutiny.groups.MultiCreate v;
io.smallrye.mutiny.groups.MultiCreate$2 v;
v := @this: io.smallrye.mutiny.groups.MultiCreate$2;
v := @parameter: io.smallrye.mutiny.groups.MultiCreate;
v := @parameter: java.util.concurrent.Flow$Publisher;
v.<io.smallrye.mutiny.groups.MultiCreate$2: io.smallrye.mutiny.groups.MultiCreate this$0> = v;
v.<io.smallrye.mutiny.groups.MultiCreate$2: java.util.concurrent.Flow$Publisher val$actual> = v;
specialinvoke v.<io.smallrye.mutiny.operators.AbstractMulti: void <init>()>();
return;
}
public void subscribe(java.util.concurrent.Flow$Subscriber)
{
java.util.concurrent.Flow$Subscriber v;
java.util.concurrent.Flow$Publisher v;
io.smallrye.mutiny.groups.MultiCreate$2 v;
io.smallrye.mutiny.subscription.SafeSubscriber v;
v := @this: io.smallrye.mutiny.groups.MultiCreate$2;
v := @parameter: java.util.concurrent.Flow$Subscriber;
v = v.<io.smallrye.mutiny.groups.MultiCreate$2: java.util.concurrent.Flow$Publisher val$actual>;
v = new io.smallrye.mutiny.subscription.SafeSubscriber;
specialinvoke v.<io.smallrye.mutiny.subscription.SafeSubscriber: void <init>(java.util.concurrent.Flow$Subscriber)>(v);
interfaceinvoke v.<java.util.concurrent.Flow$Publisher: void subscribe(java.util.concurrent.Flow$Subscriber)>(v);
return;
}
}