class io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription extends java.lang.Object implements java.util.concurrent.Flow$Subscription
{
private final io.smallrye.mutiny.subscription.MultiSubscriber downstream;
private final java.util.concurrent.atomic.AtomicLong demand;
private volatile boolean done;
private final io.smallrye.mutiny.operators.multi.replay.AppendOnlyReplayList$Cursor cursor;
private final java.util.concurrent.atomic.AtomicInteger wip;
static final boolean $assertionsDisabled;
final io.smallrye.mutiny.operators.multi.replay.ReplayOperator this$0;
private void <init>(io.smallrye.mutiny.operators.multi.replay.ReplayOperator, io.smallrye.mutiny.subscription.MultiSubscriber)
{
io.smallrye.mutiny.operators.multi.replay.AppendOnlyReplayList$Cursor v, v;
io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription v;
io.smallrye.mutiny.operators.multi.replay.AppendOnlyReplayList v;
java.util.concurrent.atomic.AtomicLong v;
io.smallrye.mutiny.operators.multi.replay.ReplayOperator v;
java.util.concurrent.atomic.AtomicInteger v;
io.smallrye.mutiny.subscription.MultiSubscriber v;
v := @this: io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription;
v := @parameter: io.smallrye.mutiny.operators.multi.replay.ReplayOperator;
v := @parameter: io.smallrye.mutiny.subscription.MultiSubscriber;
v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: io.smallrye.mutiny.operators.multi.replay.ReplayOperator this$0> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>()>();
v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: java.util.concurrent.atomic.AtomicLong demand> = v;
v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: boolean done> = 0;
v = new java.util.concurrent.atomic.AtomicInteger;
specialinvoke v.<java.util.concurrent.atomic.AtomicInteger: void <init>()>();
v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: java.util.concurrent.atomic.AtomicInteger wip> = v;
v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: io.smallrye.mutiny.subscription.MultiSubscriber downstream> = v;
v = v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator: io.smallrye.mutiny.operators.multi.replay.AppendOnlyReplayList replayList>;
v = virtualinvoke v.<io.smallrye.mutiny.operators.multi.replay.AppendOnlyReplayList: io.smallrye.mutiny.operators.multi.replay.AppendOnlyReplayList$Cursor newCursor()>();
v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: io.smallrye.mutiny.operators.multi.replay.AppendOnlyReplayList$Cursor cursor> = v;
v = v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: io.smallrye.mutiny.operators.multi.replay.AppendOnlyReplayList$Cursor cursor>;
virtualinvoke v.<io.smallrye.mutiny.operators.multi.replay.AppendOnlyReplayList$Cursor: boolean hasNext()>();
return;
}
public void request(long)
{
io.smallrye.mutiny.operators.multi.replay.AppendOnlyReplayList$Cursor v;
long v;
java.lang.IllegalArgumentException v;
io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription v;
java.util.concurrent.atomic.AtomicLong v;
byte v;
io.smallrye.mutiny.subscription.MultiSubscriber v;
boolean v, v;
v := @this: io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription;
v := @parameter: long;
v = v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: boolean done>;
if v == 0 goto label;
return;
label:
v = v cmp 0L;
if v > 0 goto label;
virtualinvoke v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: void cancel()>();
v = v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: io.smallrye.mutiny.subscription.MultiSubscriber downstream>;
v = staticinvoke <io.smallrye.mutiny.helpers.Subscriptions: java.lang.IllegalArgumentException getInvalidRequestException()>();
interfaceinvoke v.<io.smallrye.mutiny.subscription.MultiSubscriber: void onFailure(java.lang.Throwable)>(v);
return;
label:
v = v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: java.util.concurrent.atomic.AtomicLong demand>;
staticinvoke <io.smallrye.mutiny.helpers.Subscriptions: long add(java.util.concurrent.atomic.AtomicLong,long)>(v, v);
v = v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: io.smallrye.mutiny.operators.multi.replay.AppendOnlyReplayList$Cursor cursor>;
v = virtualinvoke v.<io.smallrye.mutiny.operators.multi.replay.AppendOnlyReplayList$Cursor: boolean hasNext()>();
if v == 0 goto label;
specialinvoke v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: void drain()>();
label:
return;
}
public void cancel()
{
io.smallrye.mutiny.operators.multi.replay.ReplayOperator v;
io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription v;
java.util.concurrent.CopyOnWriteArrayList v;
v := @this: io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription;
v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: boolean done> = 1;
v = v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: io.smallrye.mutiny.operators.multi.replay.ReplayOperator this$0>;
v = v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator: java.util.concurrent.CopyOnWriteArrayList subscriptions>;
virtualinvoke v.<java.util.concurrent.CopyOnWriteArrayList: boolean remove(java.lang.Object)>(v);
return;
}
private void drain()
{
java.lang.Throwable v;
long v, v, v;
java.lang.AssertionError v;
io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription v;
byte v;
java.util.concurrent.atomic.AtomicInteger v, v;
int v, v;
io.smallrye.mutiny.subscription.MultiSubscriber v, v, v;
boolean v, v, v, v, v, v, v;
io.smallrye.mutiny.operators.multi.replay.AppendOnlyReplayList$Cursor v, v, v, v, v, v, v;
java.util.concurrent.atomic.AtomicLong v, v;
java.lang.Object v;
v := @this: io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription;
v = v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: boolean done>;
if v == 0 goto label;
return;
label:
v = v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: java.util.concurrent.atomic.AtomicInteger wip>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int getAndIncrement()>();
if v <= 0 goto label;
return;
label:
v = v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: boolean done>;
if v == 0 goto label;
return;
label:
v = v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: java.util.concurrent.atomic.AtomicLong demand>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long get()>();
v = 0L;
label:
v = v cmp v;
if v >= 0 goto label;
v = v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: io.smallrye.mutiny.operators.multi.replay.AppendOnlyReplayList$Cursor cursor>;
v = virtualinvoke v.<io.smallrye.mutiny.operators.multi.replay.AppendOnlyReplayList$Cursor: boolean hasNext()>();
if v == 0 goto label;
v = v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: boolean done>;
if v == 0 goto label;
return;
label:
v = v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: io.smallrye.mutiny.operators.multi.replay.AppendOnlyReplayList$Cursor cursor>;
virtualinvoke v.<io.smallrye.mutiny.operators.multi.replay.AppendOnlyReplayList$Cursor: void moveToNext()>();
v = v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: io.smallrye.mutiny.operators.multi.replay.AppendOnlyReplayList$Cursor cursor>;
v = virtualinvoke v.<io.smallrye.mutiny.operators.multi.replay.AppendOnlyReplayList$Cursor: boolean hasReachedCompletion()>();
if v == 0 goto label;
virtualinvoke v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: void cancel()>();
v = v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: io.smallrye.mutiny.operators.multi.replay.AppendOnlyReplayList$Cursor cursor>;
virtualinvoke v.<io.smallrye.mutiny.operators.multi.replay.AppendOnlyReplayList$Cursor: void readCompletion()>();
v = v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: io.smallrye.mutiny.subscription.MultiSubscriber downstream>;
interfaceinvoke v.<io.smallrye.mutiny.subscription.MultiSubscriber: void onComplete()>();
return;
label:
v = v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: io.smallrye.mutiny.operators.multi.replay.AppendOnlyReplayList$Cursor cursor>;
v = virtualinvoke v.<io.smallrye.mutiny.operators.multi.replay.AppendOnlyReplayList$Cursor: boolean hasReachedFailure()>();
if v == 0 goto label;
virtualinvoke v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: void cancel()>();
v = v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: io.smallrye.mutiny.subscription.MultiSubscriber downstream>;
v = v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: io.smallrye.mutiny.operators.multi.replay.AppendOnlyReplayList$Cursor cursor>;
v = virtualinvoke v.<io.smallrye.mutiny.operators.multi.replay.AppendOnlyReplayList$Cursor: java.lang.Throwable readFailure()>();
interfaceinvoke v.<io.smallrye.mutiny.subscription.MultiSubscriber: void onFailure(java.lang.Throwable)>(v);
return;
label:
v = v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: io.smallrye.mutiny.operators.multi.replay.AppendOnlyReplayList$Cursor cursor>;
v = virtualinvoke v.<io.smallrye.mutiny.operators.multi.replay.AppendOnlyReplayList$Cursor: java.lang.Object read()>();
v = <io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: boolean $assertionsDisabled>;
if v != 0 goto label;
if v != null goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>()>();
throw v;
label:
v = v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: io.smallrye.mutiny.subscription.MultiSubscriber downstream>;
interfaceinvoke v.<io.smallrye.mutiny.subscription.MultiSubscriber: void onItem(java.lang.Object)>(v);
v = v + 1L;
goto label;
label:
v = v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: java.util.concurrent.atomic.AtomicLong demand>;
v = neg v;
virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long addAndGet(long)>(v);
v = v.<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: java.util.concurrent.atomic.AtomicInteger wip>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int decrementAndGet()>();
if v != 0 goto label;
return;
}
static void <clinit>()
{
java.lang.Class v;
boolean v, v;
v = class "Lio/smallrye/mutiny/operators/multi/replay/ReplayOperator;";
v = virtualinvoke v.<java.lang.Class: boolean desiredAssertionStatus()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
<io.smallrye.mutiny.operators.multi.replay.ReplayOperator$ReplaySubscription: boolean $assertionsDisabled> = v;
return;
}
}