public class io.smallrye.mutiny.helpers.spies.UniOnSubscribeSpy extends io.smallrye.mutiny.helpers.spies.UniSpyBase
{
private volatile io.smallrye.mutiny.subscription.UniSubscription lastSubscription;
public io.smallrye.mutiny.subscription.UniSubscription lastSubscription()
{
io.smallrye.mutiny.subscription.UniSubscription v;
io.smallrye.mutiny.helpers.spies.UniOnSubscribeSpy v;
v := @this: io.smallrye.mutiny.helpers.spies.UniOnSubscribeSpy;
v = v.<io.smallrye.mutiny.helpers.spies.UniOnSubscribeSpy: io.smallrye.mutiny.subscription.UniSubscription lastSubscription>;
return v;
}
void <init>(io.smallrye.mutiny.Uni)
{
io.smallrye.mutiny.helpers.spies.UniOnSubscribeSpy v;
io.smallrye.mutiny.Uni v;
v := @this: io.smallrye.mutiny.helpers.spies.UniOnSubscribeSpy;
v := @parameter: io.smallrye.mutiny.Uni;
specialinvoke v.<io.smallrye.mutiny.helpers.spies.UniSpyBase: void <init>(io.smallrye.mutiny.Uni)>(v);
return;
}
public void reset()
{
io.smallrye.mutiny.helpers.spies.UniOnSubscribeSpy v;
v := @this: io.smallrye.mutiny.helpers.spies.UniOnSubscribeSpy;
specialinvoke v.<io.smallrye.mutiny.helpers.spies.UniSpyBase: void reset()>();
v.<io.smallrye.mutiny.helpers.spies.UniOnSubscribeSpy: io.smallrye.mutiny.subscription.UniSubscription lastSubscription> = null;
return;
}
public void subscribe(io.smallrye.mutiny.subscription.UniSubscriber)
{
java.util.function.Consumer v;
io.smallrye.mutiny.groups.UniOnSubscribe v;
io.smallrye.mutiny.groups.UniSubscribe v;
io.smallrye.mutiny.subscription.UniSubscriber v;
io.smallrye.mutiny.helpers.spies.UniOnSubscribeSpy v;
io.smallrye.mutiny.Uni v, v;
v := @this: io.smallrye.mutiny.helpers.spies.UniOnSubscribeSpy;
v := @parameter: io.smallrye.mutiny.subscription.UniSubscriber;
v = virtualinvoke v.<io.smallrye.mutiny.helpers.spies.UniOnSubscribeSpy: io.smallrye.mutiny.Uni upstream()>();
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniOnSubscribe onSubscription()>();
v = staticinvoke <io.smallrye.mutiny.helpers.spies.UniOnSubscribeSpy$lambda_subscribe_0__3091: java.util.function.Consumer bootstrap$(io.smallrye.mutiny.helpers.spies.UniOnSubscribeSpy)>(v);
v = virtualinvoke v.<io.smallrye.mutiny.groups.UniOnSubscribe: io.smallrye.mutiny.Uni invoke(java.util.function.Consumer)>(v);
v = interfaceinvoke v.<io.smallrye.mutiny.Uni: io.smallrye.mutiny.groups.UniSubscribe subscribe()>();
virtualinvoke v.<io.smallrye.mutiny.groups.UniSubscribe: io.smallrye.mutiny.subscription.UniSubscriber withSubscriber(io.smallrye.mutiny.subscription.UniSubscriber)>(v);
return;
}
public java.lang.String toString()
{
io.smallrye.mutiny.subscription.UniSubscription v;
java.lang.String v, v;
io.smallrye.mutiny.helpers.spies.UniOnSubscribeSpy v;
v := @this: io.smallrye.mutiny.helpers.spies.UniOnSubscribeSpy;
v = v.<io.smallrye.mutiny.helpers.spies.UniOnSubscribeSpy: io.smallrye.mutiny.subscription.UniSubscription lastSubscription>;
v = specialinvoke v.<io.smallrye.mutiny.helpers.spies.UniSpyBase: java.lang.String toString()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (io.smallrye.mutiny.subscription.UniSubscription,java.lang.String)>(v, 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[])>("UniOnSubscribeSpy{lastSubscription=\u0001} \u0001");
return v;
}
}