public class io.smallrye.mutiny.infrastructure.Infrastructure extends java.lang.Object
{
private static final java.lang.String DISABLE_CALLBACK_DECORATORS_PROP_NAME;
private static final boolean DISABLE_CALLBACK_DECORATORS;
private static java.util.concurrent.ScheduledExecutorService DEFAULT_SCHEDULER;
private static java.util.concurrent.Executor DEFAULT_EXECUTOR;
private static io.smallrye.mutiny.infrastructure.UniInterceptor[] UNI_INTERCEPTORS;
private static io.smallrye.mutiny.infrastructure.MultiInterceptor[] MULTI_INTERCEPTORS;
private static io.smallrye.mutiny.infrastructure.CallbackDecorator[] CALLBACK_DECORATORS;
private static java.util.function.UnaryOperator completableFutureWrapper;
private static java.util.function.Consumer droppedExceptionHandler;
private static java.util.function.BooleanSupplier canCallerThreadBeBlockedSupplier;
private static io.smallrye.mutiny.infrastructure.Infrastructure$OperatorLogger operatorLogger;
private static int multiOverflowDefaultBufferSize;
public static void reload()
{
staticinvoke <io.smallrye.mutiny.infrastructure.Infrastructure: void clearInterceptors()>();
staticinvoke <io.smallrye.mutiny.infrastructure.Infrastructure: void reloadUniInterceptors()>();
staticinvoke <io.smallrye.mutiny.infrastructure.Infrastructure: void reloadMultiInterceptors()>();
staticinvoke <io.smallrye.mutiny.infrastructure.Infrastructure: void reloadCallbackDecorators()>();
<io.smallrye.mutiny.infrastructure.Infrastructure: int multiOverflowDefaultBufferSize> = 128;
return;
}
public static void setDefaultExecutor()
{
java.util.concurrent.ExecutorService v;
v = staticinvoke <java.util.concurrent.Executors: java.util.concurrent.ExecutorService newCachedThreadPool()>();
staticinvoke <io.smallrye.mutiny.infrastructure.Infrastructure: void setDefaultExecutor(java.util.concurrent.Executor)>(v);
return;
}
public static void setDefaultExecutor(java.util.concurrent.Executor)
{
java.util.concurrent.Executor v, v, v;
java.util.concurrent.ScheduledExecutorService v, v;
io.smallrye.mutiny.infrastructure.MutinyScheduler v;
boolean v, v;
v := @parameter: java.util.concurrent.Executor;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: java.util.concurrent.Executor DEFAULT_EXECUTOR>;
if v != v goto label;
return;
label:
v = <io.smallrye.mutiny.infrastructure.Infrastructure: java.util.concurrent.Executor DEFAULT_EXECUTOR>;
v = v instanceof java.util.concurrent.ExecutorService;
if v == 0 goto label;
interfaceinvoke v.<java.util.concurrent.ExecutorService: java.util.List shutdownNow()>();
label:
v = <io.smallrye.mutiny.infrastructure.Infrastructure: java.util.concurrent.ScheduledExecutorService DEFAULT_SCHEDULER>;
if v == null goto label;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: java.util.concurrent.ScheduledExecutorService DEFAULT_SCHEDULER>;
interfaceinvoke v.<java.util.concurrent.ScheduledExecutorService: java.util.List shutdownNow()>();
label:
<io.smallrye.mutiny.infrastructure.Infrastructure: java.util.concurrent.Executor DEFAULT_EXECUTOR> = v;
v = v instanceof java.util.concurrent.ScheduledExecutorService;
if v != 0 goto label;
v = new io.smallrye.mutiny.infrastructure.MutinyScheduler;
v = v;
specialinvoke v.<io.smallrye.mutiny.infrastructure.MutinyScheduler: void <init>(java.util.concurrent.Executor)>(v);
label:
<io.smallrye.mutiny.infrastructure.Infrastructure: java.util.concurrent.ScheduledExecutorService DEFAULT_SCHEDULER> = v;
return;
}
public static java.util.concurrent.ScheduledExecutorService getDefaultWorkerPool()
{
java.util.concurrent.ScheduledExecutorService v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: java.util.concurrent.ScheduledExecutorService DEFAULT_SCHEDULER>;
return v;
}
public static java.util.concurrent.Executor getDefaultExecutor()
{
java.util.concurrent.Executor v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: java.util.concurrent.Executor DEFAULT_EXECUTOR>;
return v;
}
public static io.smallrye.mutiny.Uni onUniCreation(io.smallrye.mutiny.Uni)
{
io.smallrye.mutiny.infrastructure.UniInterceptor[] v;
int v, v;
io.smallrye.mutiny.infrastructure.UniInterceptor v;
io.smallrye.mutiny.Uni v, v;
v := @parameter: io.smallrye.mutiny.Uni;
v = v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.UniInterceptor[] UNI_INTERCEPTORS>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = interfaceinvoke v.<io.smallrye.mutiny.infrastructure.UniInterceptor: io.smallrye.mutiny.Uni onUniCreation(io.smallrye.mutiny.Uni)>(v);
v = v + 1;
goto label;
label:
return v;
}
public static io.smallrye.mutiny.Multi onMultiCreation(io.smallrye.mutiny.Multi)
{
io.smallrye.mutiny.infrastructure.MultiInterceptor[] v;
io.smallrye.mutiny.infrastructure.MultiInterceptor v;
int v, v;
io.smallrye.mutiny.Multi v, v;
v := @parameter: io.smallrye.mutiny.Multi;
v = v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.MultiInterceptor[] MULTI_INTERCEPTORS>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = interfaceinvoke v.<io.smallrye.mutiny.infrastructure.MultiInterceptor: io.smallrye.mutiny.Multi onMultiCreation(io.smallrye.mutiny.Multi)>(v);
v = v + 1;
goto label;
label:
return v;
}
public static io.smallrye.mutiny.subscription.UniSubscriber onUniSubscription(io.smallrye.mutiny.Uni, io.smallrye.mutiny.subscription.UniSubscriber)
{
io.smallrye.mutiny.infrastructure.UniInterceptor[] v;
int v, v;
io.smallrye.mutiny.infrastructure.UniInterceptor v;
io.smallrye.mutiny.subscription.UniSubscriber v, v;
io.smallrye.mutiny.Uni v;
v := @parameter: io.smallrye.mutiny.Uni;
v := @parameter: io.smallrye.mutiny.subscription.UniSubscriber;
v = v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.UniInterceptor[] UNI_INTERCEPTORS>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = interfaceinvoke v.<io.smallrye.mutiny.infrastructure.UniInterceptor: io.smallrye.mutiny.subscription.UniSubscriber onSubscription(io.smallrye.mutiny.Uni,io.smallrye.mutiny.subscription.UniSubscriber)>(v, v);
v = v + 1;
goto label;
label:
return v;
}
public static java.util.concurrent.Flow$Subscriber onMultiSubscription(java.util.concurrent.Flow$Publisher, java.util.concurrent.Flow$Subscriber)
{
io.smallrye.mutiny.infrastructure.MultiInterceptor[] v;
java.util.concurrent.Flow$Subscriber v, v;
io.smallrye.mutiny.infrastructure.MultiInterceptor v;
java.util.concurrent.Flow$Publisher v;
int v, v;
v := @parameter: java.util.concurrent.Flow$Publisher;
v := @parameter: java.util.concurrent.Flow$Subscriber;
v = v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.MultiInterceptor[] MULTI_INTERCEPTORS>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = interfaceinvoke v.<io.smallrye.mutiny.infrastructure.MultiInterceptor: java.util.concurrent.Flow$Subscriber onSubscription(java.util.concurrent.Flow$Publisher,java.util.concurrent.Flow$Subscriber)>(v, v);
v = v + 1;
goto label;
label:
return v;
}
public static java.util.function.Supplier decorate(java.util.function.Supplier)
{
int v, v;
io.smallrye.mutiny.infrastructure.CallbackDecorator v;
io.smallrye.mutiny.infrastructure.CallbackDecorator[] v;
java.util.function.Supplier v, v;
v := @parameter: java.util.function.Supplier;
v = v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.CallbackDecorator[] CALLBACK_DECORATORS>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = interfaceinvoke v.<io.smallrye.mutiny.infrastructure.CallbackDecorator: java.util.function.Supplier decorate(java.util.function.Supplier)>(v);
v = v + 1;
goto label;
label:
return v;
}
public static java.util.function.Consumer decorate(java.util.function.Consumer)
{
java.util.function.Consumer v, v;
int v, v;
io.smallrye.mutiny.infrastructure.CallbackDecorator v;
io.smallrye.mutiny.infrastructure.CallbackDecorator[] v;
v := @parameter: java.util.function.Consumer;
v = v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.CallbackDecorator[] CALLBACK_DECORATORS>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = interfaceinvoke v.<io.smallrye.mutiny.infrastructure.CallbackDecorator: java.util.function.Consumer decorate(java.util.function.Consumer)>(v);
v = v + 1;
goto label;
label:
return v;
}
public static java.util.function.LongConsumer decorate(java.util.function.LongConsumer)
{
int v, v;
io.smallrye.mutiny.infrastructure.CallbackDecorator v;
io.smallrye.mutiny.infrastructure.CallbackDecorator[] v;
java.util.function.LongConsumer v, v;
v := @parameter: java.util.function.LongConsumer;
v = v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.CallbackDecorator[] CALLBACK_DECORATORS>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = interfaceinvoke v.<io.smallrye.mutiny.infrastructure.CallbackDecorator: java.util.function.LongConsumer decorate(java.util.function.LongConsumer)>(v);
v = v + 1;
goto label;
label:
return v;
}
public static java.lang.Runnable decorate(java.lang.Runnable)
{
int v, v;
io.smallrye.mutiny.infrastructure.CallbackDecorator v;
io.smallrye.mutiny.infrastructure.CallbackDecorator[] v;
java.lang.Runnable v, v;
v := @parameter: java.lang.Runnable;
v = v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.CallbackDecorator[] CALLBACK_DECORATORS>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = interfaceinvoke v.<io.smallrye.mutiny.infrastructure.CallbackDecorator: java.lang.Runnable decorate(java.lang.Runnable)>(v);
v = v + 1;
goto label;
label:
return v;
}
public static java.util.concurrent.Callable decorate(java.util.concurrent.Callable)
{
int v, v;
io.smallrye.mutiny.infrastructure.CallbackDecorator v;
java.util.concurrent.Callable v, v;
io.smallrye.mutiny.infrastructure.CallbackDecorator[] v;
v := @parameter: java.util.concurrent.Callable;
v = v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.CallbackDecorator[] CALLBACK_DECORATORS>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = interfaceinvoke v.<io.smallrye.mutiny.infrastructure.CallbackDecorator: java.util.concurrent.Callable decorate(java.util.concurrent.Callable)>(v);
v = v + 1;
goto label;
label:
return v;
}
public static java.util.function.BiConsumer decorate(java.util.function.BiConsumer)
{
int v, v;
io.smallrye.mutiny.infrastructure.CallbackDecorator v;
java.util.function.BiConsumer v, v;
io.smallrye.mutiny.infrastructure.CallbackDecorator[] v;
v := @parameter: java.util.function.BiConsumer;
v = v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.CallbackDecorator[] CALLBACK_DECORATORS>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = interfaceinvoke v.<io.smallrye.mutiny.infrastructure.CallbackDecorator: java.util.function.BiConsumer decorate(java.util.function.BiConsumer)>(v);
v = v + 1;
goto label;
label:
return v;
}
public static io.smallrye.mutiny.tuples.Functions$Function decorate(io.smallrye.mutiny.tuples.Functions$Function)
{
int v, v;
io.smallrye.mutiny.infrastructure.CallbackDecorator v;
io.smallrye.mutiny.infrastructure.CallbackDecorator[] v;
io.smallrye.mutiny.tuples.Functions$Function v, v;
v := @parameter: io.smallrye.mutiny.tuples.Functions$Function;
v = v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.CallbackDecorator[] CALLBACK_DECORATORS>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = interfaceinvoke v.<io.smallrye.mutiny.infrastructure.CallbackDecorator: io.smallrye.mutiny.tuples.Functions$Function decorate(io.smallrye.mutiny.tuples.Functions$Function)>(v);
v = v + 1;
goto label;
label:
return v;
}
public static io.smallrye.mutiny.tuples.Functions$Function decorate(io.smallrye.mutiny.tuples.Functions$Function)
{
int v, v;
io.smallrye.mutiny.infrastructure.CallbackDecorator v;
io.smallrye.mutiny.tuples.Functions$Function v, v;
io.smallrye.mutiny.infrastructure.CallbackDecorator[] v;
v := @parameter: io.smallrye.mutiny.tuples.Functions$Function;
v = v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.CallbackDecorator[] CALLBACK_DECORATORS>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = interfaceinvoke v.<io.smallrye.mutiny.infrastructure.CallbackDecorator: io.smallrye.mutiny.tuples.Functions$Function decorate(io.smallrye.mutiny.tuples.Functions$Function)>(v);
v = v + 1;
goto label;
label:
return v;
}
public static io.smallrye.mutiny.tuples.Functions$Function decorate(io.smallrye.mutiny.tuples.Functions$Function)
{
io.smallrye.mutiny.tuples.Functions$Function v, v;
int v, v;
io.smallrye.mutiny.infrastructure.CallbackDecorator v;
io.smallrye.mutiny.infrastructure.CallbackDecorator[] v;
v := @parameter: io.smallrye.mutiny.tuples.Functions$Function;
v = v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.CallbackDecorator[] CALLBACK_DECORATORS>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = interfaceinvoke v.<io.smallrye.mutiny.infrastructure.CallbackDecorator: io.smallrye.mutiny.tuples.Functions$Function decorate(io.smallrye.mutiny.tuples.Functions$Function)>(v);
v = v + 1;
goto label;
label:
return v;
}
public static io.smallrye.mutiny.tuples.Functions$Function decorate(io.smallrye.mutiny.tuples.Functions$Function)
{
io.smallrye.mutiny.tuples.Functions$Function v, v;
int v, v;
io.smallrye.mutiny.infrastructure.CallbackDecorator v;
io.smallrye.mutiny.infrastructure.CallbackDecorator[] v;
v := @parameter: io.smallrye.mutiny.tuples.Functions$Function;
v = v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.CallbackDecorator[] CALLBACK_DECORATORS>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = interfaceinvoke v.<io.smallrye.mutiny.infrastructure.CallbackDecorator: io.smallrye.mutiny.tuples.Functions$Function decorate(io.smallrye.mutiny.tuples.Functions$Function)>(v);
v = v + 1;
goto label;
label:
return v;
}
public static io.smallrye.mutiny.tuples.Functions$Function decorate(io.smallrye.mutiny.tuples.Functions$Function)
{
io.smallrye.mutiny.tuples.Functions$Function v, v;
int v, v;
io.smallrye.mutiny.infrastructure.CallbackDecorator v;
io.smallrye.mutiny.infrastructure.CallbackDecorator[] v;
v := @parameter: io.smallrye.mutiny.tuples.Functions$Function;
v = v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.CallbackDecorator[] CALLBACK_DECORATORS>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = interfaceinvoke v.<io.smallrye.mutiny.infrastructure.CallbackDecorator: io.smallrye.mutiny.tuples.Functions$Function decorate(io.smallrye.mutiny.tuples.Functions$Function)>(v);
v = v + 1;
goto label;
label:
return v;
}
public static io.smallrye.mutiny.tuples.Functions$Function decorate(io.smallrye.mutiny.tuples.Functions$Function)
{
io.smallrye.mutiny.tuples.Functions$Function v, v;
int v, v;
io.smallrye.mutiny.infrastructure.CallbackDecorator v;
io.smallrye.mutiny.infrastructure.CallbackDecorator[] v;
v := @parameter: io.smallrye.mutiny.tuples.Functions$Function;
v = v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.CallbackDecorator[] CALLBACK_DECORATORS>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = interfaceinvoke v.<io.smallrye.mutiny.infrastructure.CallbackDecorator: io.smallrye.mutiny.tuples.Functions$Function decorate(io.smallrye.mutiny.tuples.Functions$Function)>(v);
v = v + 1;
goto label;
label:
return v;
}
public static io.smallrye.mutiny.tuples.Functions$Function decorate(io.smallrye.mutiny.tuples.Functions$Function)
{
io.smallrye.mutiny.tuples.Functions$Function v, v;
int v, v;
io.smallrye.mutiny.infrastructure.CallbackDecorator v;
io.smallrye.mutiny.infrastructure.CallbackDecorator[] v;
v := @parameter: io.smallrye.mutiny.tuples.Functions$Function;
v = v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.CallbackDecorator[] CALLBACK_DECORATORS>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = interfaceinvoke v.<io.smallrye.mutiny.infrastructure.CallbackDecorator: io.smallrye.mutiny.tuples.Functions$Function decorate(io.smallrye.mutiny.tuples.Functions$Function)>(v);
v = v + 1;
goto label;
label:
return v;
}
public static java.util.function.Function decorate(java.util.function.Function)
{
int v, v;
io.smallrye.mutiny.infrastructure.CallbackDecorator v;
io.smallrye.mutiny.infrastructure.CallbackDecorator[] v;
java.util.function.Function v, v;
v := @parameter: java.util.function.Function;
v = v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.CallbackDecorator[] CALLBACK_DECORATORS>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = interfaceinvoke v.<io.smallrye.mutiny.infrastructure.CallbackDecorator: java.util.function.Function decorate(java.util.function.Function)>(v);
v = v + 1;
goto label;
label:
return v;
}
public static java.util.function.BiFunction decorate(java.util.function.BiFunction)
{
java.util.function.BiFunction v, v;
int v, v;
io.smallrye.mutiny.infrastructure.CallbackDecorator v;
io.smallrye.mutiny.infrastructure.CallbackDecorator[] v;
v := @parameter: java.util.function.BiFunction;
v = v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.CallbackDecorator[] CALLBACK_DECORATORS>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = interfaceinvoke v.<io.smallrye.mutiny.infrastructure.CallbackDecorator: java.util.function.BiFunction decorate(java.util.function.BiFunction)>(v);
v = v + 1;
goto label;
label:
return v;
}
public static java.util.function.BinaryOperator decorate(java.util.function.BinaryOperator)
{
int v, v;
io.smallrye.mutiny.infrastructure.CallbackDecorator v;
io.smallrye.mutiny.infrastructure.CallbackDecorator[] v;
java.util.function.BinaryOperator v, v;
v := @parameter: java.util.function.BinaryOperator;
v = v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.CallbackDecorator[] CALLBACK_DECORATORS>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = interfaceinvoke v.<io.smallrye.mutiny.infrastructure.CallbackDecorator: java.util.function.BinaryOperator decorate(java.util.function.BinaryOperator)>(v);
v = v + 1;
goto label;
label:
return v;
}
public static io.smallrye.mutiny.tuples.Functions$TriConsumer decorate(io.smallrye.mutiny.tuples.Functions$TriConsumer)
{
io.smallrye.mutiny.tuples.Functions$TriConsumer v, v;
int v, v;
io.smallrye.mutiny.infrastructure.CallbackDecorator v;
io.smallrye.mutiny.infrastructure.CallbackDecorator[] v;
v := @parameter: io.smallrye.mutiny.tuples.Functions$TriConsumer;
v = v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.CallbackDecorator[] CALLBACK_DECORATORS>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = interfaceinvoke v.<io.smallrye.mutiny.infrastructure.CallbackDecorator: io.smallrye.mutiny.tuples.Functions$TriConsumer decorate(io.smallrye.mutiny.tuples.Functions$TriConsumer)>(v);
v = v + 1;
goto label;
label:
return v;
}
public static void setCompletableFutureWrapper(java.util.function.UnaryOperator)
{
java.util.function.UnaryOperator v;
v := @parameter: java.util.function.UnaryOperator;
<io.smallrye.mutiny.infrastructure.Infrastructure: java.util.function.UnaryOperator completableFutureWrapper> = v;
return;
}
public static java.util.concurrent.CompletableFuture wrapCompletableFuture(java.util.concurrent.CompletableFuture)
{
java.lang.Object v;
java.util.concurrent.CompletableFuture v;
java.util.function.UnaryOperator v;
v := @parameter: java.util.concurrent.CompletableFuture;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: java.util.function.UnaryOperator completableFutureWrapper>;
if v == null goto label;
v = interfaceinvoke v.<java.util.function.UnaryOperator: java.lang.Object apply(java.lang.Object)>(v);
goto label;
label:
v = v;
label:
return v;
}
public static void handleDroppedException(java.lang.Throwable)
{
java.lang.Throwable v;
java.util.function.Consumer v;
v := @parameter: java.lang.Throwable;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: java.util.function.Consumer droppedExceptionHandler>;
interfaceinvoke v.<java.util.function.Consumer: void accept(java.lang.Object)>(v);
return;
}
public static void setCanCallerThreadBeBlockedSupplier(java.util.function.BooleanSupplier)
{
java.util.function.BooleanSupplier v;
v := @parameter: java.util.function.BooleanSupplier;
staticinvoke <io.smallrye.mutiny.helpers.ParameterValidation: java.lang.Object nonNull(java.lang.Object,java.lang.String)>(v, "supplier");
<io.smallrye.mutiny.infrastructure.Infrastructure: java.util.function.BooleanSupplier canCallerThreadBeBlockedSupplier> = v;
return;
}
public static boolean canCallerThreadBeBlocked()
{
boolean v;
java.util.function.BooleanSupplier v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: java.util.function.BooleanSupplier canCallerThreadBeBlockedSupplier>;
v = interfaceinvoke v.<java.util.function.BooleanSupplier: boolean getAsBoolean()>();
return v;
}
public static void setDroppedExceptionHandler(java.util.function.Consumer)
{
java.util.function.Consumer v;
v := @parameter: java.util.function.Consumer;
staticinvoke <io.smallrye.mutiny.helpers.ParameterValidation: java.lang.Object nonNull(java.lang.Object,java.lang.String)>(v, "handler");
<io.smallrye.mutiny.infrastructure.Infrastructure: java.util.function.Consumer droppedExceptionHandler> = v;
return;
}
public static void reloadUniInterceptors()
{
java.util.List v;
java.lang.Object[] v;
io.smallrye.mutiny.infrastructure.UniInterceptor[] v;
java.util.ServiceLoader v;
v = staticinvoke <java.util.ServiceLoader: java.util.ServiceLoader load(java.lang.Class)>(class "Lio/smallrye/mutiny/infrastructure/UniInterceptor;");
v = staticinvoke <io.smallrye.mutiny.infrastructure.Infrastructure: java.util.List toInterceptorList(java.util.ServiceLoader)>(v);
v = <io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.UniInterceptor[] UNI_INTERCEPTORS>;
v = interfaceinvoke v.<java.util.List: java.lang.Object[] toArray(java.lang.Object[])>(v);
<io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.UniInterceptor[] UNI_INTERCEPTORS> = v;
return;
}
public static void reloadMultiInterceptors()
{
io.smallrye.mutiny.infrastructure.MultiInterceptor[] v;
java.util.List v;
java.lang.Object[] v;
java.util.ServiceLoader v;
v = staticinvoke <java.util.ServiceLoader: java.util.ServiceLoader load(java.lang.Class)>(class "Lio/smallrye/mutiny/infrastructure/MultiInterceptor;");
v = staticinvoke <io.smallrye.mutiny.infrastructure.Infrastructure: java.util.List toInterceptorList(java.util.ServiceLoader)>(v);
v = <io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.MultiInterceptor[] MULTI_INTERCEPTORS>;
v = interfaceinvoke v.<java.util.List: java.lang.Object[] toArray(java.lang.Object[])>(v);
<io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.MultiInterceptor[] MULTI_INTERCEPTORS> = v;
return;
}
public static void reloadCallbackDecorators()
{
java.util.List v;
java.lang.Object[] v;
java.util.ServiceLoader v;
io.smallrye.mutiny.infrastructure.CallbackDecorator[] v;
boolean v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: boolean DISABLE_CALLBACK_DECORATORS>;
if v != 0 goto label;
v = staticinvoke <java.util.ServiceLoader: java.util.ServiceLoader load(java.lang.Class)>(class "Lio/smallrye/mutiny/infrastructure/CallbackDecorator;");
v = staticinvoke <io.smallrye.mutiny.infrastructure.Infrastructure: java.util.List toInterceptorList(java.util.ServiceLoader)>(v);
v = <io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.CallbackDecorator[] CALLBACK_DECORATORS>;
v = interfaceinvoke v.<java.util.List: java.lang.Object[] toArray(java.lang.Object[])>(v);
<io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.CallbackDecorator[] CALLBACK_DECORATORS> = v;
label:
return;
}
private static java.util.List toInterceptorList(java.util.ServiceLoader)
{
java.util.Iterator v;
java.lang.Object v;
java.util.ServiceLoader v;
io.smallrye.mutiny.infrastructure.Infrastructure$MutinyInterceptorComparator v;
boolean v;
java.util.ArrayList v;
v := @parameter: java.util.ServiceLoader;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = virtualinvoke v.<java.util.ServiceLoader: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = <io.smallrye.mutiny.infrastructure.Infrastructure$MutinyInterceptorComparator: io.smallrye.mutiny.infrastructure.Infrastructure$MutinyInterceptorComparator INSTANCE>;
interfaceinvoke v.<java.util.List: void sort(java.util.Comparator)>(v);
return v;
}
public static void clearInterceptors()
{
io.smallrye.mutiny.infrastructure.MultiInterceptor[] v;
io.smallrye.mutiny.infrastructure.CallbackDecorator[] v;
io.smallrye.mutiny.infrastructure.UniInterceptor[] v;
v = newarray (io.smallrye.mutiny.infrastructure.UniInterceptor)[0];
<io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.UniInterceptor[] UNI_INTERCEPTORS> = v;
v = newarray (io.smallrye.mutiny.infrastructure.MultiInterceptor)[0];
<io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.MultiInterceptor[] MULTI_INTERCEPTORS> = v;
v = newarray (io.smallrye.mutiny.infrastructure.CallbackDecorator)[0];
<io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.CallbackDecorator[] CALLBACK_DECORATORS> = v;
return;
}
public static void resetDroppedExceptionHandler()
{
io.smallrye.mutiny.infrastructure.Infrastructure$PrintAndDumpThrowableConsumer v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure$PrintAndDumpThrowableConsumer: io.smallrye.mutiny.infrastructure.Infrastructure$PrintAndDumpThrowableConsumer INSTANCE>;
<io.smallrye.mutiny.infrastructure.Infrastructure: java.util.function.Consumer droppedExceptionHandler> = v;
return;
}
public static void resetCanCallerThreadBeBlockedSupplier()
{
io.smallrye.mutiny.infrastructure.Infrastructure$AlwaysTrueBooleanSupplier v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure$AlwaysTrueBooleanSupplier: io.smallrye.mutiny.infrastructure.Infrastructure$AlwaysTrueBooleanSupplier INSTANCE>;
<io.smallrye.mutiny.infrastructure.Infrastructure: java.util.function.BooleanSupplier canCallerThreadBeBlockedSupplier> = v;
return;
}
private void <init>()
{
io.smallrye.mutiny.infrastructure.Infrastructure v;
v := @this: io.smallrye.mutiny.infrastructure.Infrastructure;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public static java.util.function.BooleanSupplier decorate(java.util.function.BooleanSupplier)
{
int v, v;
io.smallrye.mutiny.infrastructure.CallbackDecorator v;
io.smallrye.mutiny.infrastructure.CallbackDecorator[] v;
java.util.function.BooleanSupplier v, v;
v := @parameter: java.util.function.BooleanSupplier;
v = v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.CallbackDecorator[] CALLBACK_DECORATORS>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = interfaceinvoke v.<io.smallrye.mutiny.infrastructure.CallbackDecorator: java.util.function.BooleanSupplier decorate(java.util.function.BooleanSupplier)>(v);
v = v + 1;
goto label;
label:
return v;
}
public static java.util.function.Predicate decorate(java.util.function.Predicate)
{
java.util.function.Predicate v, v;
int v, v;
io.smallrye.mutiny.infrastructure.CallbackDecorator v;
io.smallrye.mutiny.infrastructure.CallbackDecorator[] v;
v := @parameter: java.util.function.Predicate;
v = v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.CallbackDecorator[] CALLBACK_DECORATORS>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = interfaceinvoke v.<io.smallrye.mutiny.infrastructure.CallbackDecorator: java.util.function.Predicate decorate(java.util.function.Predicate)>(v);
v = v + 1;
goto label;
label:
return v;
}
public static void logFromOperator(java.lang.String, java.lang.String, java.lang.Object, java.lang.Throwable)
{
java.lang.Throwable v;
io.smallrye.mutiny.infrastructure.Infrastructure$OperatorLogger v;
java.lang.Object v;
java.lang.String v, v;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Object;
v := @parameter: java.lang.Throwable;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.Infrastructure$OperatorLogger operatorLogger>;
interfaceinvoke v.<io.smallrye.mutiny.infrastructure.Infrastructure$OperatorLogger: void log(java.lang.String,java.lang.String,java.lang.Object,java.lang.Throwable)>(v, v, v, v);
return;
}
public static void setOperatorLogger(io.smallrye.mutiny.infrastructure.Infrastructure$OperatorLogger)
{
io.smallrye.mutiny.infrastructure.Infrastructure$OperatorLogger v;
java.lang.Object v;
v := @parameter: io.smallrye.mutiny.infrastructure.Infrastructure$OperatorLogger;
v = staticinvoke <io.smallrye.mutiny.helpers.ParameterValidation: java.lang.Object nonNull(java.lang.Object,java.lang.String)>(v, "operatorLogger");
<io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.Infrastructure$OperatorLogger operatorLogger> = v;
return;
}
public static void resetOperatorLogger()
{
io.smallrye.mutiny.infrastructure.Infrastructure$PrintOperatorEventOperatorLogger v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure$PrintOperatorEventOperatorLogger: io.smallrye.mutiny.infrastructure.Infrastructure$PrintOperatorEventOperatorLogger INSTANCE>;
<io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.Infrastructure$OperatorLogger operatorLogger> = v;
return;
}
public static int getMultiOverflowDefaultBufferSize()
{
int v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure: int multiOverflowDefaultBufferSize>;
return v;
}
public static void setMultiOverflowDefaultBufferSize(int)
{
int v, v;
v := @parameter: int;
v = staticinvoke <io.smallrye.mutiny.helpers.ParameterValidation: int positive(int,java.lang.String)>(v, "size");
<io.smallrye.mutiny.infrastructure.Infrastructure: int multiOverflowDefaultBufferSize> = v;
return;
}
static void <clinit>()
{
java.util.Iterator v;
java.util.concurrent.Executor v;
io.smallrye.mutiny.infrastructure.Infrastructure$PrintOperatorEventOperatorLogger v;
java.util.ServiceLoader v;
java.lang.Object v, v;
io.smallrye.mutiny.infrastructure.Infrastructure$PrintAndDumpThrowableConsumer v;
boolean v, v;
v = staticinvoke <java.lang.Boolean: boolean getBoolean(java.lang.String)>("mutiny.disableCallBackDecorators");
<io.smallrye.mutiny.infrastructure.Infrastructure: boolean DISABLE_CALLBACK_DECORATORS> = v;
v = staticinvoke <java.util.ServiceLoader: java.util.ServiceLoader load(java.lang.Class)>(class "Lio/smallrye/mutiny/infrastructure/ExecutorConfiguration;");
v = virtualinvoke v.<java.util.ServiceLoader: java.util.Iterator iterator()>();
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<io.smallrye.mutiny.infrastructure.ExecutorConfiguration: java.util.concurrent.Executor getDefaultWorkerExecutor()>();
v = staticinvoke <io.smallrye.mutiny.helpers.ParameterValidation: java.lang.Object nonNull(java.lang.Object,java.lang.String)>(v, "executor");
staticinvoke <io.smallrye.mutiny.infrastructure.Infrastructure: void setDefaultExecutor(java.util.concurrent.Executor)>(v);
goto label;
label:
staticinvoke <io.smallrye.mutiny.infrastructure.Infrastructure: void setDefaultExecutor()>();
label:
staticinvoke <io.smallrye.mutiny.infrastructure.Infrastructure: void reload()>();
staticinvoke <io.smallrye.mutiny.infrastructure.Infrastructure: void resetCanCallerThreadBeBlockedSupplier()>();
v = <io.smallrye.mutiny.infrastructure.Infrastructure$PrintAndDumpThrowableConsumer: io.smallrye.mutiny.infrastructure.Infrastructure$PrintAndDumpThrowableConsumer INSTANCE>;
<io.smallrye.mutiny.infrastructure.Infrastructure: java.util.function.Consumer droppedExceptionHandler> = v;
v = <io.smallrye.mutiny.infrastructure.Infrastructure$PrintOperatorEventOperatorLogger: io.smallrye.mutiny.infrastructure.Infrastructure$PrintOperatorEventOperatorLogger INSTANCE>;
<io.smallrye.mutiny.infrastructure.Infrastructure: io.smallrye.mutiny.infrastructure.Infrastructure$OperatorLogger operatorLogger> = v;
<io.smallrye.mutiny.infrastructure.Infrastructure: int multiOverflowDefaultBufferSize> = 128;
return;
}
}