public class io.smallrye.mutiny.helpers.test.UniAssertSubscriber extends java.lang.Object implements io.smallrye.mutiny.subscription.UniSubscriber
{
private volatile boolean cancelImmediatelyOnSubscription;
private final io.smallrye.mutiny.Context context;
private final java.util.concurrent.CompletableFuture completion;
private final java.util.concurrent.CompletableFuture subscribed;
private final java.util.concurrent.CompletableFuture hasCompleted;
private final java.util.concurrent.CompletableFuture hasSubscription;
private volatile io.smallrye.mutiny.subscription.UniSubscription subscription;
private volatile java.lang.Object item;
private volatile java.lang.Throwable failure;
private volatile boolean hasCompletedSuccessfully;
private volatile java.lang.String onResultThreadName;
private volatile java.lang.String onErrorThreadName;
private volatile java.lang.String onSubscribeThreadName;
private final java.util.List signals;
public void <init>(io.smallrye.mutiny.Context, boolean)
{
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v;
java.util.concurrent.CompletableFuture v, v, v, v, v, v, v, v;
io.smallrye.mutiny.Context v;
java.util.function.Function v;
java.util.ArrayList v;
java.util.function.BiConsumer v;
java.lang.Object v;
boolean v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v := @parameter: io.smallrye.mutiny.Context;
v := @parameter: boolean;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.concurrent.CompletableFuture;
specialinvoke v.<java.util.concurrent.CompletableFuture: void <init>()>();
v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.util.concurrent.CompletableFuture completion> = v;
v = new java.util.concurrent.CompletableFuture;
specialinvoke v.<java.util.concurrent.CompletableFuture: void <init>()>();
v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.util.concurrent.CompletableFuture subscribed> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(4);
v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.util.List signals> = v;
v = staticinvoke <io.smallrye.mutiny.helpers.ParameterValidation: java.lang.Object nonNull(java.lang.Object,java.lang.String)>(v, "context");
v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: io.smallrye.mutiny.Context context> = v;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.util.concurrent.CompletableFuture completion>;
v = staticinvoke <io.smallrye.mutiny.helpers.test.UniAssertSubscriber$lambda_new_0__2794: java.util.function.BiConsumer bootstrap$(io.smallrye.mutiny.helpers.test.UniAssertSubscriber)>(v);
v = virtualinvoke v.<java.util.concurrent.CompletableFuture: java.util.concurrent.CompletableFuture whenComplete(java.util.function.BiConsumer)>(v);
v = virtualinvoke v.<java.util.concurrent.CompletableFuture: java.util.concurrent.CompletableFuture toCompletableFuture()>();
v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.util.concurrent.CompletableFuture hasCompleted> = v;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.util.concurrent.CompletableFuture subscribed>;
v = staticinvoke <io.smallrye.mutiny.helpers.test.UniAssertSubscriber$lambda_new_1__2795: java.util.function.Function bootstrap$(io.smallrye.mutiny.helpers.test.UniAssertSubscriber)>(v);
v = virtualinvoke v.<java.util.concurrent.CompletableFuture: java.util.concurrent.CompletableFuture thenApply(java.util.function.Function)>(v);
v = virtualinvoke v.<java.util.concurrent.CompletableFuture: java.util.concurrent.CompletableFuture toCompletableFuture()>();
v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.util.concurrent.CompletableFuture hasSubscription> = v;
v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: boolean cancelImmediatelyOnSubscription> = v;
return;
}
public void <init>(boolean)
{
io.smallrye.mutiny.Context v;
boolean v;
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v := @parameter: boolean;
v = staticinvoke <io.smallrye.mutiny.Context: io.smallrye.mutiny.Context empty()>();
specialinvoke v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: void <init>(io.smallrye.mutiny.Context,boolean)>(v, v);
return;
}
public void <init>()
{
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
specialinvoke v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: void <init>(boolean)>(0);
return;
}
public static io.smallrye.mutiny.helpers.test.UniAssertSubscriber create()
{
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v;
v = new io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
specialinvoke v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: void <init>()>();
return v;
}
public static io.smallrye.mutiny.helpers.test.UniAssertSubscriber create(io.smallrye.mutiny.Context)
{
io.smallrye.mutiny.Context v;
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v;
v := @parameter: io.smallrye.mutiny.Context;
v = new io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
specialinvoke v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: void <init>(io.smallrye.mutiny.Context,boolean)>(v, 0);
return v;
}
public io.smallrye.mutiny.Context context()
{
io.smallrye.mutiny.Context v;
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: io.smallrye.mutiny.Context context>;
return v;
}
public synchronized void onSubscribe(io.smallrye.mutiny.subscription.UniSubscription)
{
io.smallrye.mutiny.subscription.UniSubscription v;
java.util.List v;
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v;
java.util.concurrent.CompletableFuture v, v;
io.smallrye.mutiny.helpers.test.OnSubscribeUniSignal v;
boolean v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v := @parameter: io.smallrye.mutiny.subscription.UniSubscription;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.util.List signals>;
v = new io.smallrye.mutiny.helpers.test.OnSubscribeUniSignal;
specialinvoke v.<io.smallrye.mutiny.helpers.test.OnSubscribeUniSignal: void <init>(io.smallrye.mutiny.subscription.UniSubscription)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.util.concurrent.CompletableFuture subscribed>;
virtualinvoke v.<java.util.concurrent.CompletableFuture: boolean complete(java.lang.Object)>(v);
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: boolean cancelImmediatelyOnSubscription>;
if v == 0 goto label;
interfaceinvoke v.<io.smallrye.mutiny.subscription.UniSubscription: void cancel()>();
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.util.concurrent.CompletableFuture completion>;
virtualinvoke v.<java.util.concurrent.CompletableFuture: boolean cancel(boolean)>(0);
label:
return;
}
public synchronized void onItem(java.lang.Object)
{
java.util.List v;
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v;
io.smallrye.mutiny.helpers.test.OnItemUniSignal v;
java.lang.Object v;
java.util.concurrent.CompletableFuture v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v := @parameter: java.lang.Object;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.util.List signals>;
v = new io.smallrye.mutiny.helpers.test.OnItemUniSignal;
specialinvoke v.<io.smallrye.mutiny.helpers.test.OnItemUniSignal: void <init>(java.lang.Object)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.util.concurrent.CompletableFuture completion>;
virtualinvoke v.<java.util.concurrent.CompletableFuture: boolean complete(java.lang.Object)>(v);
return;
}
public synchronized void onFailure(java.lang.Throwable)
{
java.lang.Throwable v;
java.util.List v;
io.smallrye.mutiny.helpers.test.OnFailureUniSignal v;
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v;
java.util.concurrent.CompletableFuture v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v := @parameter: java.lang.Throwable;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.util.List signals>;
v = new io.smallrye.mutiny.helpers.test.OnFailureUniSignal;
specialinvoke v.<io.smallrye.mutiny.helpers.test.OnFailureUniSignal: void <init>(java.lang.Throwable)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.util.concurrent.CompletableFuture completion>;
virtualinvoke v.<java.util.concurrent.CompletableFuture: boolean completeExceptionally(java.lang.Throwable)>(v);
return;
}
public io.smallrye.mutiny.helpers.test.UniAssertSubscriber awaitItem()
{
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v, v;
java.time.Duration v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v = <io.smallrye.mutiny.helpers.test.AssertSubscriber: java.time.Duration DEFAULT_TIMEOUT>;
v = virtualinvoke v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: io.smallrye.mutiny.helpers.test.UniAssertSubscriber awaitItem(java.time.Duration)>(v);
return v;
}
public io.smallrye.mutiny.helpers.test.UniAssertSubscriber awaitItem(java.time.Duration)
{
java.lang.Throwable v, v;
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v;
java.util.concurrent.TimeoutException v;
java.util.concurrent.CompletableFuture v;
long v;
java.lang.AssertionError v, v;
java.time.Duration v;
java.lang.String v, v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v := @parameter: java.time.Duration;
label:
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.util.concurrent.CompletableFuture hasCompleted>;
specialinvoke v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: void awaitEvent(java.util.concurrent.CompletableFuture,java.time.Duration)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.AssertionError;
v = virtualinvoke v.<java.time.Duration: long toMillis()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("No item (or failure) event received in the last \u ms");
specialinvoke v.<java.lang.AssertionError: void <init>(java.lang.Object)>(v);
throw v;
label:
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.lang.Throwable failure>;
if v != null goto label;
return v;
label:
v = new java.lang.AssertionError;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.lang.Throwable failure>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Throwable)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Expected an item event but got a failure: \u0001");
specialinvoke v.<java.lang.AssertionError: void <init>(java.lang.Object)>(v);
throw v;
catch java.util.concurrent.TimeoutException from label to label with label;
}
public io.smallrye.mutiny.helpers.test.UniAssertSubscriber awaitFailure()
{
java.util.function.Consumer v;
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v, v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v = staticinvoke <io.smallrye.mutiny.helpers.test.UniAssertSubscriber$lambda_awaitFailure_2__2796: java.util.function.Consumer bootstrap$()>();
v = virtualinvoke v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: io.smallrye.mutiny.helpers.test.UniAssertSubscriber awaitFailure(java.util.function.Consumer)>(v);
return v;
}
public io.smallrye.mutiny.helpers.test.UniAssertSubscriber awaitFailure(java.util.function.Consumer)
{
java.util.function.Consumer v;
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v, v;
java.time.Duration v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v := @parameter: java.util.function.Consumer;
v = <io.smallrye.mutiny.helpers.test.AssertSubscriber: java.time.Duration DEFAULT_TIMEOUT>;
v = virtualinvoke v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: io.smallrye.mutiny.helpers.test.UniAssertSubscriber awaitFailure(java.util.function.Consumer,java.time.Duration)>(v, v);
return v;
}
public io.smallrye.mutiny.helpers.test.UniAssertSubscriber awaitFailure(java.time.Duration)
{
java.util.function.Consumer v;
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v, v;
java.time.Duration v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v := @parameter: java.time.Duration;
v = staticinvoke <io.smallrye.mutiny.helpers.test.UniAssertSubscriber$lambda_awaitFailure_3__2797: java.util.function.Consumer bootstrap$()>();
v = virtualinvoke v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: io.smallrye.mutiny.helpers.test.UniAssertSubscriber awaitFailure(java.util.function.Consumer,java.time.Duration)>(v, v);
return v;
}
public io.smallrye.mutiny.helpers.test.UniAssertSubscriber awaitFailure(java.util.function.Consumer, java.time.Duration)
{
java.lang.Throwable v, v;
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v;
java.util.concurrent.TimeoutException v;
java.util.concurrent.CompletableFuture v;
long v;
java.lang.AssertionError v, v, v, v;
java.time.Duration v;
java.lang.String v, v, v;
java.util.function.Consumer v;
java.lang.Object v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v := @parameter: java.util.function.Consumer;
v := @parameter: java.time.Duration;
label:
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.util.concurrent.CompletableFuture hasCompleted>;
specialinvoke v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: void awaitEvent(java.util.concurrent.CompletableFuture,java.time.Duration)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.AssertionError;
v = virtualinvoke v.<java.time.Duration: long toMillis()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("No item (or failure) event received in the last \u ms");
specialinvoke v.<java.lang.AssertionError: void <init>(java.lang.Object)>(v);
throw v;
label:
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.lang.Throwable failure>;
if v != null goto label;
v = new java.lang.AssertionError;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.lang.Object item>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Object)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Expected a failure event but got an item event: \u0001");
specialinvoke v.<java.lang.AssertionError: void <init>(java.lang.Object)>(v);
throw v;
label:
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.lang.Throwable failure>;
interfaceinvoke v.<java.util.function.Consumer: void accept(java.lang.Object)>(v);
label:
return v;
label:
v := @caughtexception;
v = new java.lang.AssertionError;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.AssertionError)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Received a failure event, but that failure did not pass the validation: \u0001");
specialinvoke v.<java.lang.AssertionError: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch java.util.concurrent.TimeoutException from label to label with label;
catch java.lang.AssertionError from label to label with label;
}
public io.smallrye.mutiny.helpers.test.UniAssertSubscriber awaitSubscription()
{
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v, v;
java.time.Duration v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v = <io.smallrye.mutiny.helpers.test.AssertSubscriber: java.time.Duration DEFAULT_TIMEOUT>;
v = virtualinvoke v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: io.smallrye.mutiny.helpers.test.UniAssertSubscriber awaitSubscription(java.time.Duration)>(v);
return v;
}
public io.smallrye.mutiny.helpers.test.UniAssertSubscriber awaitSubscription(java.time.Duration)
{
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v;
java.time.Duration v;
java.util.concurrent.TimeoutException v;
java.util.concurrent.CompletableFuture v;
long v;
java.lang.AssertionError v;
java.lang.String v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v := @parameter: java.time.Duration;
label:
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.util.concurrent.CompletableFuture hasSubscription>;
specialinvoke v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: void awaitEvent(java.util.concurrent.CompletableFuture,java.time.Duration)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.AssertionError;
v = virtualinvoke v.<java.time.Duration: long toMillis()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Expecting a subscription event in the last \u ms, but did not get it");
specialinvoke v.<java.lang.AssertionError: void <init>(java.lang.Object)>(v);
throw v;
label:
return v;
catch java.util.concurrent.TimeoutException from label to label with label;
}
private void awaitEvent(java.util.concurrent.CompletableFuture, java.time.Duration) throws java.util.concurrent.TimeoutException
{
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v;
java.util.concurrent.CompletableFuture v;
long v;
java.util.concurrent.ExecutionException v;
java.util.concurrent.TimeUnit v;
java.lang.InterruptedException v;
java.lang.Thread v;
java.time.Duration v;
boolean v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v := @parameter: java.util.concurrent.CompletableFuture;
v := @parameter: java.time.Duration;
v = virtualinvoke v.<java.util.concurrent.CompletableFuture: boolean isDone()>();
if v == 0 goto label;
return;
label:
v = virtualinvoke v.<java.time.Duration: long toMillis()>();
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
virtualinvoke v.<java.util.concurrent.CompletableFuture: java.lang.Object get(long,java.util.concurrent.TimeUnit)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
goto label;
label:
v := @caughtexception;
label:
return;
catch java.lang.InterruptedException from label to label with label;
catch java.util.concurrent.ExecutionException from label to label with label;
}
public synchronized io.smallrye.mutiny.helpers.test.UniAssertSubscriber assertCompleted()
{
java.lang.Throwable v;
boolean v;
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: boolean hasCompletedSuccessfully>;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.lang.Throwable failure>;
staticinvoke <io.smallrye.mutiny.helpers.test.AssertionHelper: void shouldHaveCompleted(boolean,java.lang.Throwable,java.util.List)>(v, v, null);
return v;
}
public synchronized io.smallrye.mutiny.helpers.test.UniAssertSubscriber assertFailed()
{
java.lang.Throwable v;
boolean v;
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: boolean hasCompletedSuccessfully>;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.lang.Throwable failure>;
staticinvoke <io.smallrye.mutiny.helpers.test.AssertionHelper: void shouldHaveFailed(boolean,java.lang.Throwable,java.lang.Class,java.lang.String)>(v, v, null, null);
return v;
}
public synchronized java.lang.Object getItem()
{
java.lang.Object v;
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.lang.Object item>;
return v;
}
public synchronized java.lang.Throwable getFailure()
{
java.lang.Throwable v, v;
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v;
boolean v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.lang.Throwable failure>;
v = v instanceof java.util.concurrent.CancellationException;
if v == 0 goto label;
return null;
label:
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.lang.Throwable failure>;
return v;
}
public io.smallrye.mutiny.helpers.test.UniAssertSubscriber assertItem(java.lang.Object)
{
java.lang.Throwable v;
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v;
java.lang.Object v, v;
boolean v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v := @parameter: java.lang.Object;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: boolean hasCompletedSuccessfully>;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.lang.Throwable failure>;
staticinvoke <io.smallrye.mutiny.helpers.test.AssertionHelper: void shouldHaveCompleted(boolean,java.lang.Throwable,java.util.List)>(v, v, null);
v = virtualinvoke v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.lang.Object getItem()>();
staticinvoke <io.smallrye.mutiny.helpers.test.AssertionHelper: void shouldHaveReceived(java.lang.Object,java.lang.Object)>(v, v);
return v;
}
public io.smallrye.mutiny.helpers.test.UniAssertSubscriber assertFailedWith(java.lang.Class, java.lang.String)
{
java.lang.Throwable v;
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v;
java.lang.Class v;
java.lang.String v;
boolean v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v := @parameter: java.lang.Class;
v := @parameter: java.lang.String;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: boolean hasCompletedSuccessfully>;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.lang.Throwable failure>;
staticinvoke <io.smallrye.mutiny.helpers.test.AssertionHelper: void shouldHaveFailed(boolean,java.lang.Throwable,java.lang.Class,java.lang.String)>(v, v, v, v);
return v;
}
public io.smallrye.mutiny.helpers.test.UniAssertSubscriber assertFailedWith(java.lang.Class)
{
java.lang.Throwable v;
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v;
java.lang.Class v;
boolean v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v := @parameter: java.lang.Class;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: boolean hasCompletedSuccessfully>;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.lang.Throwable failure>;
staticinvoke <io.smallrye.mutiny.helpers.test.AssertionHelper: void shouldHaveFailed(boolean,java.lang.Throwable,java.lang.Class,java.lang.String)>(v, v, v, null);
return v;
}
public java.lang.String getOnItemThreadName()
{
java.lang.String v;
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.lang.String onResultThreadName>;
return v;
}
public java.lang.String getOnFailureThreadName()
{
java.lang.String v;
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.lang.String onErrorThreadName>;
return v;
}
public java.lang.String getOnSubscribeThreadName()
{
java.lang.String v;
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.lang.String onSubscribeThreadName>;
return v;
}
public void cancel()
{
io.smallrye.mutiny.subscription.UniSubscription v, v;
java.util.List v;
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v;
io.smallrye.mutiny.helpers.test.OnCancellationUniSignal v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.util.List signals>;
v = new io.smallrye.mutiny.helpers.test.OnCancellationUniSignal;
specialinvoke v.<io.smallrye.mutiny.helpers.test.OnCancellationUniSignal: void <init>()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: io.smallrye.mutiny.subscription.UniSubscription subscription>;
if v != null goto label;
v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: boolean cancelImmediatelyOnSubscription> = 1;
goto label;
label:
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: io.smallrye.mutiny.subscription.UniSubscription subscription>;
interfaceinvoke v.<io.smallrye.mutiny.subscription.UniSubscription: void cancel()>();
label:
return;
}
public io.smallrye.mutiny.helpers.test.UniAssertSubscriber assertTerminated()
{
java.lang.Throwable v;
boolean v;
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: boolean hasCompletedSuccessfully>;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.lang.Throwable failure>;
staticinvoke <io.smallrye.mutiny.helpers.test.AssertionHelper: void shouldBeTerminated(boolean,java.lang.Throwable)>(v, v);
return v;
}
public io.smallrye.mutiny.helpers.test.UniAssertSubscriber assertNotTerminated()
{
java.lang.Throwable v;
boolean v;
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: boolean hasCompletedSuccessfully>;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.lang.Throwable failure>;
staticinvoke <io.smallrye.mutiny.helpers.test.AssertionHelper: void shouldNotBeTerminatedUni(boolean,java.lang.Throwable)>(v, v);
return v;
}
public io.smallrye.mutiny.helpers.test.UniAssertSubscriber assertSubscribed()
{
io.smallrye.mutiny.subscription.UniSubscription v;
byte v;
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: io.smallrye.mutiny.subscription.UniSubscription subscription>;
if v != null goto label;
v = 0;
goto label;
label:
v = 1;
label:
staticinvoke <io.smallrye.mutiny.helpers.test.AssertionHelper: void shouldBeSubscribed(int)>(v);
return v;
}
public io.smallrye.mutiny.helpers.test.UniAssertSubscriber assertNotSubscribed()
{
io.smallrye.mutiny.subscription.UniSubscription v;
byte v;
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: io.smallrye.mutiny.subscription.UniSubscription subscription>;
if v != null goto label;
v = 0;
goto label;
label:
v = 1;
label:
staticinvoke <io.smallrye.mutiny.helpers.test.AssertionHelper: void shouldNotBeSubscribed(int)>(v);
return v;
}
public java.util.List getSignals()
{
java.util.List v, v;
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.util.List signals>;
v = staticinvoke <java.util.Collections: java.util.List unmodifiableList(java.util.List)>(v);
return v;
}
public io.smallrye.mutiny.helpers.test.UniAssertSubscriber assertSignalsReceivedInOrder()
{
int[] v;
boolean v, v, v, v, v, v, v;
java.util.List v, v, v, v, v, v, v;
io.smallrye.mutiny.helpers.test.UniAssertSubscriber v;
java.lang.AssertionError v, v, v, v, v;
int v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v;
java.util.Iterator v;
java.lang.Object v, v;
v := @this: io.smallrye.mutiny.helpers.test.UniAssertSubscriber;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.util.List signals>;
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v == 0 goto label;
return v;
label:
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.util.List signals>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = v instanceof io.smallrye.mutiny.helpers.test.OnSubscribeUniSignal;
if v != 0 goto label;
v = v instanceof io.smallrye.mutiny.helpers.test.OnCancellationUniSignal;
if v != 0 goto label;
v = new java.lang.AssertionError;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (io.smallrye.mutiny.helpers.test.UniSignal)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("The first signal is neither onSubscribe nor cancel but \u0001");
specialinvoke v.<java.lang.AssertionError: void <init>(java.lang.Object)>(v);
throw v;
label:
v = newarray (int)[3];
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.util.List signals>;
v = interfaceinvoke v.<java.util.List: 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()>();
v = v instanceof io.smallrye.mutiny.helpers.test.OnSubscribeUniSignal;
if v == 0 goto label;
v = v[0];
v = v + 1;
v[0] = v;
goto label;
label:
v = v instanceof io.smallrye.mutiny.helpers.test.OnItemUniSignal;
if v == 0 goto label;
v = v[1];
v = v + 1;
v[1] = v;
goto label;
label:
v = v instanceof io.smallrye.mutiny.helpers.test.OnFailureUniSignal;
if v == 0 goto label;
v = v[2];
v = v + 1;
v[2] = v;
goto label;
label:
v = v[0];
if v <= 1 goto label;
v = new java.lang.AssertionError;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.util.List signals>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.util.List)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("There are more than 1 onSubscribe signals in \u0001");
specialinvoke v.<java.lang.AssertionError: void <init>(java.lang.Object)>(v);
throw v;
label:
v = v[1];
if v <= 1 goto label;
v = new java.lang.AssertionError;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.util.List signals>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.util.List)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("There are more than 1 onItem signals in \u0001");
specialinvoke v.<java.lang.AssertionError: void <init>(java.lang.Object)>(v);
throw v;
label:
v = v[2];
if v <= 1 goto label;
v = new java.lang.AssertionError;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.util.List signals>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.util.List)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("There are more than 1 onFailure signals in \u0001");
specialinvoke v.<java.lang.AssertionError: void <init>(java.lang.Object)>(v);
throw v;
label:
v = v[1];
if v != 1 goto label;
v = v[2];
if v != 1 goto label;
v = new java.lang.AssertionError;
v = v.<io.smallrye.mutiny.helpers.test.UniAssertSubscriber: java.util.List signals>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.util.List)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("There are both onItem and onFailure signals in \u0001");
specialinvoke v.<java.lang.AssertionError: void <init>(java.lang.Object)>(v);
throw v;
label:
return v;
}
}