public interface  io.smallrye.mutiny.Multi extends java.lang.Object implements java.util.concurrent.Flow$Publisher
{
public static io.smallrye.mutiny.groups.MultiCreate createFrom()
{
io.smallrye.mutiny.groups.MultiCreate v;
v = <io.smallrye.mutiny.groups.MultiCreate: io.smallrye.mutiny.groups.MultiCreate INSTANCE>;
return v;
}
public static io.smallrye.mutiny.groups.MultiCreateBy createBy()
{
io.smallrye.mutiny.groups.MultiCreateBy v;
v = <io.smallrye.mutiny.groups.MultiCreateBy: io.smallrye.mutiny.groups.MultiCreateBy INSTANCE>;
return v;
}
public abstract io.smallrye.mutiny.groups.MultiSubscribe subscribe();
public abstract io.smallrye.mutiny.groups.MultiOnItem onItem();
public java.lang.Object stage(java.util.function.Function)
{
java.lang.Object v, v;
java.util.function.Function v;
io.smallrye.mutiny.Multi v;
v := @this: io.smallrye.mutiny.Multi;
v := @parameter: java.util.function.Function;
v = staticinvoke <io.smallrye.mutiny.helpers.ParameterValidation: java.lang.Object nonNull(java.lang.Object,java.lang.String)>(v, "stage");
v = interfaceinvoke v.<java.util.function.Function: java.lang.Object apply(java.lang.Object)>(v);
return v;
}
public abstract io.smallrye.mutiny.Uni toUni();
public abstract io.smallrye.mutiny.groups.MultiOnFailure onFailure();
public abstract io.smallrye.mutiny.groups.MultiOnFailure onFailure(java.util.function.Predicate);
public abstract io.smallrye.mutiny.groups.MultiOnSubscribe onSubscription();
public abstract io.smallrye.mutiny.groups.MultiOnFailure onFailure(java.lang.Class);
public abstract io.smallrye.mutiny.groups.MultiIfNoItem ifNoItem();
public abstract io.smallrye.mutiny.Multi cache();
public abstract io.smallrye.mutiny.groups.MultiCollect collect();
public abstract io.smallrye.mutiny.groups.MultiGroup group();
public abstract io.smallrye.mutiny.Multi emitOn(java.util.concurrent.Executor);
public abstract io.smallrye.mutiny.Multi runSubscriptionOn(java.util.concurrent.Executor);
public abstract io.smallrye.mutiny.groups.MultiOnCompletion onCompletion();
public abstract io.smallrye.mutiny.groups.MultiSelect select();
public abstract io.smallrye.mutiny.groups.MultiSkip skip();
public abstract io.smallrye.mutiny.groups.MultiOverflow onOverflow();
public abstract io.smallrye.mutiny.groups.MultiBroadcast broadcast();
public abstract io.smallrye.mutiny.groups.MultiConvert convert();
public io.smallrye.mutiny.Multi filter(java.util.function.Predicate)
{
io.smallrye.mutiny.groups.MultiSelect v;
java.util.function.Predicate v;
io.smallrye.mutiny.Multi v, v;
v := @this: io.smallrye.mutiny.Multi;
v := @parameter: java.util.function.Predicate;
v = interfaceinvoke v.<io.smallrye.mutiny.Multi: io.smallrye.mutiny.groups.MultiSelect select()>();
v = virtualinvoke v.<io.smallrye.mutiny.groups.MultiSelect: io.smallrye.mutiny.Multi where(java.util.function.Predicate)>(v);
return v;
}
public io.smallrye.mutiny.Multi map(java.util.function.Function)
{
io.smallrye.mutiny.groups.MultiOnItem v;
java.util.function.Function v;
io.smallrye.mutiny.Multi v, v;
v := @this: io.smallrye.mutiny.Multi;
v := @parameter: java.util.function.Function;
v = interfaceinvoke v.<io.smallrye.mutiny.Multi: io.smallrye.mutiny.groups.MultiOnItem onItem()>();
v = virtualinvoke v.<io.smallrye.mutiny.groups.MultiOnItem: io.smallrye.mutiny.Multi transform(java.util.function.Function)>(v);
return v;
}
public io.smallrye.mutiny.Multi flatMap(java.util.function.Function)
{
io.smallrye.mutiny.groups.MultiOnItem v;
java.util.function.Function v;
io.smallrye.mutiny.Multi v, v;
v := @this: io.smallrye.mutiny.Multi;
v := @parameter: java.util.function.Function;
v = interfaceinvoke v.<io.smallrye.mutiny.Multi: io.smallrye.mutiny.groups.MultiOnItem onItem()>();
v = virtualinvoke v.<io.smallrye.mutiny.groups.MultiOnItem: io.smallrye.mutiny.Multi transformToMultiAndMerge(java.util.function.Function)>(v);
return v;
}
public io.smallrye.mutiny.Multi call(java.util.function.Function)
{
io.smallrye.mutiny.groups.MultiOnItem v;
java.util.function.Function v;
io.smallrye.mutiny.Multi v, v;
v := @this: io.smallrye.mutiny.Multi;
v := @parameter: java.util.function.Function;
v = interfaceinvoke v.<io.smallrye.mutiny.Multi: io.smallrye.mutiny.groups.MultiOnItem onItem()>();
v = virtualinvoke v.<io.smallrye.mutiny.groups.MultiOnItem: io.smallrye.mutiny.Multi call(java.util.function.Function)>(v);
return v;
}
public io.smallrye.mutiny.Multi call(java.util.function.Supplier)
{
io.smallrye.mutiny.groups.MultiOnItem v;
java.util.function.Supplier v;
io.smallrye.mutiny.Multi v, v;
v := @this: io.smallrye.mutiny.Multi;
v := @parameter: java.util.function.Supplier;
v = interfaceinvoke v.<io.smallrye.mutiny.Multi: io.smallrye.mutiny.groups.MultiOnItem onItem()>();
v = virtualinvoke v.<io.smallrye.mutiny.groups.MultiOnItem: io.smallrye.mutiny.Multi call(java.util.function.Supplier)>(v);
return v;
}
public io.smallrye.mutiny.Multi invoke(java.util.function.Consumer)
{
java.util.function.Consumer v;
io.smallrye.mutiny.groups.MultiOnItem v;
java.lang.Object v;
io.smallrye.mutiny.Multi v, v;
v := @this: io.smallrye.mutiny.Multi;
v := @parameter: java.util.function.Consumer;
v = interfaceinvoke v.<io.smallrye.mutiny.Multi: io.smallrye.mutiny.groups.MultiOnItem onItem()>();
v = staticinvoke <io.smallrye.mutiny.helpers.ParameterValidation: java.lang.Object nonNull(java.lang.Object,java.lang.String)>(v, "callback");
v = virtualinvoke v.<io.smallrye.mutiny.groups.MultiOnItem: io.smallrye.mutiny.Multi invoke(java.util.function.Consumer)>(v);
return v;
}
public io.smallrye.mutiny.Multi invoke(java.lang.Runnable)
{
io.smallrye.mutiny.groups.MultiOnItem v;
java.lang.Runnable v;
io.smallrye.mutiny.Multi v, v;
v := @this: io.smallrye.mutiny.Multi;
v := @parameter: java.lang.Runnable;
v = interfaceinvoke v.<io.smallrye.mutiny.Multi: io.smallrye.mutiny.groups.MultiOnItem onItem()>();
v = virtualinvoke v.<io.smallrye.mutiny.groups.MultiOnItem: io.smallrye.mutiny.Multi invoke(java.lang.Runnable)>(v);
return v;
}
public io.smallrye.mutiny.Multi concatMap(java.util.function.Function)
{
io.smallrye.mutiny.groups.MultiOnItem v;
java.util.function.Function v;
io.smallrye.mutiny.Multi v, v;
v := @this: io.smallrye.mutiny.Multi;
v := @parameter: java.util.function.Function;
v = interfaceinvoke v.<io.smallrye.mutiny.Multi: io.smallrye.mutiny.groups.MultiOnItem onItem()>();
v = virtualinvoke v.<io.smallrye.mutiny.groups.MultiOnItem: io.smallrye.mutiny.Multi transformToMultiAndConcatenate(java.util.function.Function)>(v);
return v;
}
public abstract io.smallrye.mutiny.groups.MultiOnTerminate onTermination();
public abstract io.smallrye.mutiny.groups.MultiOnCancel onCancellation();
public abstract io.smallrye.mutiny.groups.MultiOnRequest onRequest();
public io.smallrye.mutiny.Multi plug(java.util.function.Function)
{
java.lang.Object v, v, v;
java.util.function.Function v;
io.smallrye.mutiny.Multi v, v;
v := @this: io.smallrye.mutiny.Multi;
v := @parameter: java.util.function.Function;
v = staticinvoke <io.smallrye.mutiny.helpers.ParameterValidation: java.lang.Object nonNull(java.lang.Object,java.lang.String)>(v, "operatorProvider");
v = interfaceinvoke v.<java.util.function.Function: java.lang.Object apply(java.lang.Object)>(v);
v = staticinvoke <io.smallrye.mutiny.helpers.ParameterValidation: java.lang.Object nonNull(java.lang.Object,java.lang.String)>(v, "multi");
v = staticinvoke <io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.Multi onMultiCreation(io.smallrye.mutiny.Multi)>(v);
return v;
}
public abstract io.smallrye.mutiny.Multi toHotStream();
public abstract io.smallrye.mutiny.Multi log(java.lang.String);
public abstract io.smallrye.mutiny.Multi log();
public io.smallrye.mutiny.Multi withContext(java.util.function.BiFunction)
{
java.lang.UnsupportedOperationException v;
io.smallrye.mutiny.Multi v;
java.util.function.BiFunction v;
v := @this: io.smallrye.mutiny.Multi;
v := @parameter: java.util.function.BiFunction;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>("Default method added to limit binary incompatibility");
throw v;
}
public io.smallrye.mutiny.Multi attachContext()
{
io.smallrye.mutiny.Multi v, v;
java.util.function.BiFunction v;
v := @this: io.smallrye.mutiny.Multi;
v = staticinvoke <io.smallrye.mutiny.Multi$lambda_attachContext_1__2619: java.util.function.BiFunction bootstrap$()>();
v = interfaceinvoke v.<io.smallrye.mutiny.Multi: io.smallrye.mutiny.Multi withContext(java.util.function.BiFunction)>(v);
return v;
}
public abstract io.smallrye.mutiny.groups.MultiDemandPacing paceDemand();
public io.smallrye.mutiny.Multi capDemandsTo(long)
{
java.util.function.LongFunction v;
long v, v;
io.smallrye.mutiny.Multi v, v;
v := @this: io.smallrye.mutiny.Multi;
v := @parameter: long;
v = staticinvoke <io.smallrye.mutiny.helpers.ParameterValidation: long positive(long,java.lang.String)>(v, "max");
v = staticinvoke <io.smallrye.mutiny.Multi$lambda_capDemandsTo_2__2620: java.util.function.LongFunction bootstrap$(long)>(v);
v = interfaceinvoke v.<io.smallrye.mutiny.Multi: io.smallrye.mutiny.Multi capDemandsUsing(java.util.function.LongFunction)>(v);
return v;
}
public abstract io.smallrye.mutiny.Multi capDemandsUsing(java.util.function.LongFunction);
}