final class io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber<T> extends io.reactivex.internal.subscribers.QueueDrainSubscriber<T, java.lang.Object, io.reactivex.Flowable<T>> implements org.reactivestreams.Subscription
minor version: 0
major version: 59
flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
this_class: io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber
super_class: io.reactivex.internal.subscribers.QueueDrainSubscriber
{
final long timespan;
descriptor: J
flags: (0x0010) ACC_FINAL
final java.util.concurrent.TimeUnit unit;
descriptor: Ljava/util/concurrent/TimeUnit;
flags: (0x0010) ACC_FINAL
final io.reactivex.Scheduler scheduler;
descriptor: Lio/reactivex/Scheduler;
flags: (0x0010) ACC_FINAL
final int bufferSize;
descriptor: I
flags: (0x0010) ACC_FINAL
final boolean restartTimerOnMaxSize;
descriptor: Z
flags: (0x0010) ACC_FINAL
final long maxSize;
descriptor: J
flags: (0x0010) ACC_FINAL
final io.reactivex.Scheduler$Worker worker;
descriptor: Lio/reactivex/Scheduler$Worker;
flags: (0x0010) ACC_FINAL
long count;
descriptor: J
flags: (0x0000)
long producerIndex;
descriptor: J
flags: (0x0000)
org.reactivestreams.Subscription upstream;
descriptor: Lorg/reactivestreams/Subscription;
flags: (0x0000)
io.reactivex.processors.UnicastProcessor<T> window;
descriptor: Lio/reactivex/processors/UnicastProcessor;
flags: (0x0000)
Signature: Lio/reactivex/processors/UnicastProcessor<TT;>;
volatile boolean terminated;
descriptor: Z
flags: (0x0040) ACC_VOLATILE
final io.reactivex.internal.disposables.SequentialDisposable timer;
descriptor: Lio/reactivex/internal/disposables/SequentialDisposable;
flags: (0x0010) ACC_FINAL
void <init>(org.reactivestreams.Subscriber<? super io.reactivex.Flowable<T>>, long, java.util.concurrent.TimeUnit, io.reactivex.Scheduler, int, long, );
descriptor: (Lorg/reactivestreams/Subscriber;JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;IJZ)V
flags: (0x0000)
Code:
stack=4, locals=10, args_size=8
start local 0 start local 1 start local 2 start local 4 start local 5 start local 6 start local 7 start local 9 0: aload 0
aload 1
new io.reactivex.internal.queue.MpscLinkedQueue
dup
invokespecial io.reactivex.internal.queue.MpscLinkedQueue.<init>:()V
invokespecial io.reactivex.internal.subscribers.QueueDrainSubscriber.<init>:(Lorg/reactivestreams/Subscriber;Lio/reactivex/internal/fuseable/SimplePlainQueue;)V
1: aload 0
new io.reactivex.internal.disposables.SequentialDisposable
dup
invokespecial io.reactivex.internal.disposables.SequentialDisposable.<init>:()V
putfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.timer:Lio/reactivex/internal/disposables/SequentialDisposable;
2: aload 0
lload 2
putfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.timespan:J
3: aload 0
aload 4
putfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.unit:Ljava/util/concurrent/TimeUnit;
4: aload 0
aload 5
putfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.scheduler:Lio/reactivex/Scheduler;
5: aload 0
iload 6
putfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.bufferSize:I
6: aload 0
lload 7
putfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.maxSize:J
7: aload 0
iload 9
putfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.restartTimerOnMaxSize:Z
8: iload 9
ifeq 11
9: aload 0
aload 5
invokevirtual io.reactivex.Scheduler.createWorker:()Lio/reactivex/Scheduler$Worker;
putfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.worker:Lio/reactivex/Scheduler$Worker;
10: goto 12
11: StackMap locals: io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber org.reactivestreams.Subscriber long java.util.concurrent.TimeUnit io.reactivex.Scheduler int long int
StackMap stack:
aload 0
aconst_null
putfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.worker:Lio/reactivex/Scheduler$Worker;
12: StackMap locals:
StackMap stack:
return
end local 9 end local 7 end local 6 end local 5 end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lio/reactivex/internal/operators/flowable/FlowableWindowTimed$WindowExactBoundedSubscriber<TT;>;
0 13 1 actual Lorg/reactivestreams/Subscriber<-Lio/reactivex/Flowable<TT;>;>;
0 13 2 timespan J
0 13 4 unit Ljava/util/concurrent/TimeUnit;
0 13 5 scheduler Lio/reactivex/Scheduler;
0 13 6 bufferSize I
0 13 7 maxSize J
0 13 9 restartTimerOnMaxSize Z
Signature: (Lorg/reactivestreams/Subscriber<-Lio/reactivex/Flowable<TT;>;>;JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;IJZ)V
MethodParameters:
Name Flags
actual
timespan
unit
scheduler
bufferSize
maxSize
restartTimerOnMaxSize
public void onSubscribe(org.reactivestreams.Subscription);
descriptor: (Lorg/reactivestreams/Subscription;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=8, args_size=2
start local 0 start local 1 0: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.upstream:Lorg/reactivestreams/Subscription;
aload 1
invokestatic io.reactivex.internal.subscriptions.SubscriptionHelper.validate:(Lorg/reactivestreams/Subscription;Lorg/reactivestreams/Subscription;)Z
ifeq 25
1: aload 0
aload 1
putfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.upstream:Lorg/reactivestreams/Subscription;
2: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.downstream:Lorg/reactivestreams/Subscriber;
astore 2
start local 2 3: aload 2
aload 0
invokeinterface org.reactivestreams.Subscriber.onSubscribe:(Lorg/reactivestreams/Subscription;)V
4: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.cancelled:Z
ifeq 6
5: return
6: StackMap locals: org.reactivestreams.Subscriber
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.bufferSize:I
invokestatic io.reactivex.processors.UnicastProcessor.create:(I)Lio/reactivex/processors/UnicastProcessor;
astore 3
start local 3 7: aload 0
aload 3
putfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.window:Lio/reactivex/processors/UnicastProcessor;
8: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.requested:()J
lstore 4
start local 4 9: lload 4
lconst_0
lcmp
ifeq 14
10: aload 2
aload 3
invokeinterface org.reactivestreams.Subscriber.onNext:(Ljava/lang/Object;)V
11: lload 4
ldc 9223372036854775807
lcmp
ifeq 18
12: aload 0
lconst_1
invokevirtual io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.produced:(J)J
pop2
13: goto 18
14: StackMap locals: io.reactivex.processors.UnicastProcessor long
StackMap stack:
aload 0
iconst_1
putfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.cancelled:Z
15: aload 1
invokeinterface org.reactivestreams.Subscription.cancel:()V
16: aload 2
new io.reactivex.exceptions.MissingBackpressureException
dup
ldc "Could not deliver initial window due to lack of requests."
invokespecial io.reactivex.exceptions.MissingBackpressureException.<init>:(Ljava/lang/String;)V
invokeinterface org.reactivestreams.Subscriber.onError:(Ljava/lang/Throwable;)V
17: return
18: StackMap locals:
StackMap stack:
new io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber$ConsumerIndexHolder
dup
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.producerIndex:J
aload 0
invokespecial io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber$ConsumerIndexHolder.<init>:(JLio/reactivex/internal/operators/flowable/FlowableWindowTimed$WindowExactBoundedSubscriber;)V
astore 7
start local 7 19: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.restartTimerOnMaxSize:Z
ifeq 22
20: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.worker:Lio/reactivex/Scheduler$Worker;
aload 7
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.timespan:J
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.timespan:J
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.unit:Ljava/util/concurrent/TimeUnit;
invokevirtual io.reactivex.Scheduler$Worker.schedulePeriodically:(Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Lio/reactivex/disposables/Disposable;
astore 6
start local 6 21: goto 23
end local 6 22: StackMap locals: io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber org.reactivestreams.Subscription org.reactivestreams.Subscriber io.reactivex.processors.UnicastProcessor long top io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber$ConsumerIndexHolder
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.scheduler:Lio/reactivex/Scheduler;
aload 7
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.timespan:J
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.timespan:J
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.unit:Ljava/util/concurrent/TimeUnit;
invokevirtual io.reactivex.Scheduler.schedulePeriodicallyDirect:(Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Lio/reactivex/disposables/Disposable;
astore 6
start local 6 23: StackMap locals: io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber org.reactivestreams.Subscription org.reactivestreams.Subscriber io.reactivex.processors.UnicastProcessor long io.reactivex.disposables.Disposable io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber$ConsumerIndexHolder
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.timer:Lio/reactivex/internal/disposables/SequentialDisposable;
aload 6
invokevirtual io.reactivex.internal.disposables.SequentialDisposable.replace:(Lio/reactivex/disposables/Disposable;)Z
ifeq 25
24: aload 1
ldc 9223372036854775807
invokeinterface org.reactivestreams.Subscription.request:(J)V
end local 7 end local 6 end local 4 end local 3 end local 2 25: StackMap locals: io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber org.reactivestreams.Subscription
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 26 0 this Lio/reactivex/internal/operators/flowable/FlowableWindowTimed$WindowExactBoundedSubscriber<TT;>;
0 26 1 s Lorg/reactivestreams/Subscription;
3 25 2 a Lorg/reactivestreams/Subscriber<-Lio/reactivex/Flowable<TT;>;>;
7 25 3 w Lio/reactivex/processors/UnicastProcessor<TT;>;
9 25 4 r J
21 22 6 task Lio/reactivex/disposables/Disposable;
23 25 6 task Lio/reactivex/disposables/Disposable;
19 25 7 consumerIndexHolder Lio/reactivex/internal/operators/flowable/FlowableWindowTimed$WindowExactBoundedSubscriber$ConsumerIndexHolder;
MethodParameters:
Name Flags
s
public void onNext();
descriptor: (Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=9, args_size=2
start local 0 start local 1 0: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.terminated:Z
ifeq 2
1: return
2: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.fastEnter:()Z
ifeq 33
3: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.window:Lio/reactivex/processors/UnicastProcessor;
astore 2
start local 2 4: aload 2
aload 1
invokevirtual io.reactivex.processors.UnicastProcessor.onNext:(Ljava/lang/Object;)V
5: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.count:J
lconst_1
ladd
lstore 3
start local 3 6: lload 3
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.maxSize:J
lcmp
iflt 30
7: aload 0
dup
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.producerIndex:J
lconst_1
ladd
putfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.producerIndex:J
8: aload 0
lconst_0
putfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.count:J
9: aload 2
invokevirtual io.reactivex.processors.UnicastProcessor.onComplete:()V
10: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.requested:()J
lstore 5
start local 5 11: lload 5
lconst_0
lcmp
ifeq 25
12: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.bufferSize:I
invokestatic io.reactivex.processors.UnicastProcessor.create:(I)Lio/reactivex/processors/UnicastProcessor;
astore 2
13: aload 0
aload 2
putfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.window:Lio/reactivex/processors/UnicastProcessor;
14: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.downstream:Lorg/reactivestreams/Subscriber;
aload 2
invokeinterface org.reactivestreams.Subscriber.onNext:(Ljava/lang/Object;)V
15: lload 5
ldc 9223372036854775807
lcmp
ifeq 17
16: aload 0
lconst_1
invokevirtual io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.produced:(J)J
pop2
17: StackMap locals: io.reactivex.processors.UnicastProcessor long long
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.restartTimerOnMaxSize:Z
ifeq 31
18: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.timer:Lio/reactivex/internal/disposables/SequentialDisposable;
invokevirtual io.reactivex.internal.disposables.SequentialDisposable.get:()Ljava/lang/Object;
checkcast io.reactivex.disposables.Disposable
astore 7
start local 7 19: aload 7
invokeinterface io.reactivex.disposables.Disposable.dispose:()V
20: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.worker:Lio/reactivex/Scheduler$Worker;
21: new io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber$ConsumerIndexHolder
dup
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.producerIndex:J
aload 0
invokespecial io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber$ConsumerIndexHolder.<init>:(JLio/reactivex/internal/operators/flowable/FlowableWindowTimed$WindowExactBoundedSubscriber;)V
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.timespan:J
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.timespan:J
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.unit:Ljava/util/concurrent/TimeUnit;
22: invokevirtual io.reactivex.Scheduler$Worker.schedulePeriodically:(Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Lio/reactivex/disposables/Disposable;
astore 8
start local 8 23: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.timer:Lio/reactivex/internal/disposables/SequentialDisposable;
aload 8
invokevirtual io.reactivex.internal.disposables.SequentialDisposable.replace:(Lio/reactivex/disposables/Disposable;)Z
pop
end local 8 end local 7 24: goto 31
25: StackMap locals:
StackMap stack:
aload 0
aconst_null
putfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.window:Lio/reactivex/processors/UnicastProcessor;
26: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.upstream:Lorg/reactivestreams/Subscription;
invokeinterface org.reactivestreams.Subscription.cancel:()V
27: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.downstream:Lorg/reactivestreams/Subscriber;
new io.reactivex.exceptions.MissingBackpressureException
dup
ldc "Could not deliver window due to lack of requests"
invokespecial io.reactivex.exceptions.MissingBackpressureException.<init>:(Ljava/lang/String;)V
invokeinterface org.reactivestreams.Subscriber.onError:(Ljava/lang/Throwable;)V
28: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.dispose:()V
29: return
end local 5 30: StackMap locals:
StackMap stack:
aload 0
lload 3
putfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.count:J
31: StackMap locals:
StackMap stack:
aload 0
iconst_m1
invokevirtual io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.leave:(I)I
ifne 36
32: return
end local 3 end local 2 33: StackMap locals:
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
aload 1
invokestatic io.reactivex.internal.util.NotificationLite.next:(Ljava/lang/Object;)Ljava/lang/Object;
invokeinterface io.reactivex.internal.fuseable.SimplePlainQueue.offer:(Ljava/lang/Object;)Z
pop
34: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.enter:()Z
ifne 36
35: return
36: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.drainLoop:()V
37: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 38 0 this Lio/reactivex/internal/operators/flowable/FlowableWindowTimed$WindowExactBoundedSubscriber<TT;>;
0 38 1 t TT;
4 33 2 w Lio/reactivex/processors/UnicastProcessor<TT;>;
6 33 3 c J
11 30 5 r J
19 24 7 tm Lio/reactivex/disposables/Disposable;
23 24 8 task Lio/reactivex/disposables/Disposable;
Signature: (TT;)V
MethodParameters:
Name Flags
t
public void onError(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.error:Ljava/lang/Throwable;
1: aload 0
iconst_1
putfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.done:Z
2: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.enter:()Z
ifeq 4
3: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.drainLoop:()V
4: StackMap locals:
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.downstream:Lorg/reactivestreams/Subscriber;
aload 1
invokeinterface org.reactivestreams.Subscriber.onError:(Ljava/lang/Throwable;)V
5: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.dispose:()V
6: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/reactivex/internal/operators/flowable/FlowableWindowTimed$WindowExactBoundedSubscriber<TT;>;
0 7 1 t Ljava/lang/Throwable;
MethodParameters:
Name Flags
t
public void onComplete();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
iconst_1
putfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.done:Z
1: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.enter:()Z
ifeq 3
2: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.drainLoop:()V
3: StackMap locals:
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.downstream:Lorg/reactivestreams/Subscriber;
invokeinterface org.reactivestreams.Subscriber.onComplete:()V
4: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.dispose:()V
5: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/reactivex/internal/operators/flowable/FlowableWindowTimed$WindowExactBoundedSubscriber<TT;>;
public void request(long);
descriptor: (J)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
lload 1
invokevirtual io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.requested:(J)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/internal/operators/flowable/FlowableWindowTimed$WindowExactBoundedSubscriber<TT;>;
0 2 1 n J
MethodParameters:
Name Flags
n
public void cancel();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
iconst_1
putfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.cancelled:Z
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/internal/operators/flowable/FlowableWindowTimed$WindowExactBoundedSubscriber<TT;>;
public void dispose();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=2, args_size=1
start local 0 0: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.timer:Lio/reactivex/internal/disposables/SequentialDisposable;
invokestatic io.reactivex.internal.disposables.DisposableHelper.dispose:(Ljava/util/concurrent/atomic/AtomicReference;)Z
pop
1: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.worker:Lio/reactivex/Scheduler$Worker;
astore 1
start local 1 2: aload 1
ifnull 4
3: aload 1
invokevirtual io.reactivex.Scheduler$Worker.dispose:()V
4: StackMap locals: io.reactivex.Scheduler$Worker
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/reactivex/internal/operators/flowable/FlowableWindowTimed$WindowExactBoundedSubscriber<TT;>;
2 5 1 w Lio/reactivex/Scheduler$Worker;
void drainLoop();
descriptor: ()V
flags: (0x0000)
Code:
stack=7, locals=15, args_size=1
start local 0 0: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
astore 1
start local 1 1: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.downstream:Lorg/reactivestreams/Subscriber;
astore 2
start local 2 2: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.window:Lio/reactivex/processors/UnicastProcessor;
astore 3
start local 3 3: iconst_1
istore 4
start local 4 4: StackMap locals: io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber io.reactivex.internal.fuseable.SimplePlainQueue org.reactivestreams.Subscriber io.reactivex.processors.UnicastProcessor int
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.terminated:Z
ifeq 9
5: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.upstream:Lorg/reactivestreams/Subscription;
invokeinterface org.reactivestreams.Subscription.cancel:()V
6: aload 1
invokeinterface io.reactivex.internal.fuseable.SimplePlainQueue.clear:()V
7: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.dispose:()V
8: return
9: StackMap locals:
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.done:Z
istore 5
start local 5 10: aload 1
invokeinterface io.reactivex.internal.fuseable.SimplePlainQueue.poll:()Ljava/lang/Object;
astore 6
start local 6 11: aload 6
ifnonnull 12
iconst_1
goto 13
StackMap locals: int java.lang.Object
StackMap stack:
12: iconst_0
StackMap locals:
StackMap stack: int
13: istore 7
start local 7 14: aload 6
instanceof io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber$ConsumerIndexHolder
istore 8
start local 8 15: iload 5
ifeq 25
iload 7
ifne 16
iload 8
ifeq 25
16: StackMap locals: int int
StackMap stack:
aload 0
aconst_null
putfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.window:Lio/reactivex/processors/UnicastProcessor;
17: aload 1
invokeinterface io.reactivex.internal.fuseable.SimplePlainQueue.clear:()V
18: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.error:Ljava/lang/Throwable;
astore 9
start local 9 19: aload 9
ifnull 22
20: aload 3
aload 9
invokevirtual io.reactivex.processors.UnicastProcessor.onError:(Ljava/lang/Throwable;)V
21: goto 23
22: StackMap locals: java.lang.Throwable
StackMap stack:
aload 3
invokevirtual io.reactivex.processors.UnicastProcessor.onComplete:()V
23: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.dispose:()V
24: return
end local 9 25: StackMap locals:
StackMap stack:
iload 7
ifeq 27
26: goto 74
27: StackMap locals:
StackMap stack:
iload 8
ifeq 46
28: aload 6
checkcast io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber$ConsumerIndexHolder
astore 9
start local 9 29: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.restartTimerOnMaxSize:Z
ifne 30
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.producerIndex:J
aload 9
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber$ConsumerIndexHolder.index:J
lcmp
ifne 4
30: StackMap locals: io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber$ConsumerIndexHolder
StackMap stack:
aload 3
invokevirtual io.reactivex.processors.UnicastProcessor.onComplete:()V
31: aload 0
lconst_0
putfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.count:J
32: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.bufferSize:I
invokestatic io.reactivex.processors.UnicastProcessor.create:(I)Lio/reactivex/processors/UnicastProcessor;
astore 3
33: aload 0
aload 3
putfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.window:Lio/reactivex/processors/UnicastProcessor;
34: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.requested:()J
lstore 10
start local 10 35: lload 10
lconst_0
lcmp
ifeq 40
36: aload 2
aload 3
invokeinterface org.reactivestreams.Subscriber.onNext:(Ljava/lang/Object;)V
37: lload 10
ldc 9223372036854775807
lcmp
ifeq 4
38: aload 0
lconst_1
invokevirtual io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.produced:(J)J
pop2
39: goto 4
40: StackMap locals: long
StackMap stack:
aload 0
aconst_null
putfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.window:Lio/reactivex/processors/UnicastProcessor;
41: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
invokeinterface io.reactivex.internal.fuseable.SimplePlainQueue.clear:()V
42: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.upstream:Lorg/reactivestreams/Subscription;
invokeinterface org.reactivestreams.Subscription.cancel:()V
43: aload 2
new io.reactivex.exceptions.MissingBackpressureException
dup
ldc "Could not deliver first window due to lack of requests."
invokespecial io.reactivex.exceptions.MissingBackpressureException.<init>:(Ljava/lang/String;)V
invokeinterface org.reactivestreams.Subscriber.onError:(Ljava/lang/Throwable;)V
44: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.dispose:()V
45: return
end local 10 end local 9 46: StackMap locals:
StackMap stack:
aload 3
aload 6
invokestatic io.reactivex.internal.util.NotificationLite.getValue:(Ljava/lang/Object;)Ljava/lang/Object;
invokevirtual io.reactivex.processors.UnicastProcessor.onNext:(Ljava/lang/Object;)V
47: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.count:J
lconst_1
ladd
lstore 9
start local 9 48: lload 9
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.maxSize:J
lcmp
iflt 72
49: aload 0
dup
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.producerIndex:J
lconst_1
ladd
putfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.producerIndex:J
50: aload 0
lconst_0
putfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.count:J
51: aload 3
invokevirtual io.reactivex.processors.UnicastProcessor.onComplete:()V
52: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.requested:()J
lstore 11
start local 11 53: lload 11
lconst_0
lcmp
ifeq 67
54: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.bufferSize:I
invokestatic io.reactivex.processors.UnicastProcessor.create:(I)Lio/reactivex/processors/UnicastProcessor;
astore 3
55: aload 0
aload 3
putfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.window:Lio/reactivex/processors/UnicastProcessor;
56: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.downstream:Lorg/reactivestreams/Subscriber;
aload 3
invokeinterface org.reactivestreams.Subscriber.onNext:(Ljava/lang/Object;)V
57: lload 11
ldc 9223372036854775807
lcmp
ifeq 59
58: aload 0
lconst_1
invokevirtual io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.produced:(J)J
pop2
59: StackMap locals: long long
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.restartTimerOnMaxSize:Z
ifeq 4
60: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.timer:Lio/reactivex/internal/disposables/SequentialDisposable;
invokevirtual io.reactivex.internal.disposables.SequentialDisposable.get:()Ljava/lang/Object;
checkcast io.reactivex.disposables.Disposable
astore 13
start local 13 61: aload 13
invokeinterface io.reactivex.disposables.Disposable.dispose:()V
62: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.worker:Lio/reactivex/Scheduler$Worker;
63: new io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber$ConsumerIndexHolder
dup
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.producerIndex:J
aload 0
invokespecial io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber$ConsumerIndexHolder.<init>:(JLio/reactivex/internal/operators/flowable/FlowableWindowTimed$WindowExactBoundedSubscriber;)V
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.timespan:J
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.timespan:J
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.unit:Ljava/util/concurrent/TimeUnit;
64: invokevirtual io.reactivex.Scheduler$Worker.schedulePeriodically:(Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Lio/reactivex/disposables/Disposable;
astore 14
start local 14 65: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.timer:Lio/reactivex/internal/disposables/SequentialDisposable;
aload 14
invokevirtual io.reactivex.internal.disposables.SequentialDisposable.replace:(Lio/reactivex/disposables/Disposable;)Z
pop
end local 14 end local 13 66: goto 4
67: StackMap locals:
StackMap stack:
aload 0
aconst_null
putfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.window:Lio/reactivex/processors/UnicastProcessor;
68: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.upstream:Lorg/reactivestreams/Subscription;
invokeinterface org.reactivestreams.Subscription.cancel:()V
69: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.downstream:Lorg/reactivestreams/Subscriber;
new io.reactivex.exceptions.MissingBackpressureException
dup
ldc "Could not deliver window due to lack of requests"
invokespecial io.reactivex.exceptions.MissingBackpressureException.<init>:(Ljava/lang/String;)V
invokeinterface org.reactivestreams.Subscriber.onError:(Ljava/lang/Throwable;)V
70: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.dispose:()V
71: return
end local 11 72: StackMap locals:
StackMap stack:
aload 0
lload 9
putfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.count:J
end local 9 end local 8 end local 7 end local 6 end local 5 73: goto 4
74: StackMap locals: io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber io.reactivex.internal.fuseable.SimplePlainQueue org.reactivestreams.Subscriber io.reactivex.processors.UnicastProcessor int
StackMap stack:
aload 0
iload 4
ineg
invokevirtual io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.leave:(I)I
istore 4
75: iload 4
ifne 4
76: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 77 0 this Lio/reactivex/internal/operators/flowable/FlowableWindowTimed$WindowExactBoundedSubscriber<TT;>;
1 77 1 q Lio/reactivex/internal/fuseable/SimplePlainQueue<Ljava/lang/Object;>;
2 77 2 a Lorg/reactivestreams/Subscriber<-Lio/reactivex/Flowable<TT;>;>;
3 77 3 w Lio/reactivex/processors/UnicastProcessor<TT;>;
4 77 4 missed I
10 73 5 d Z
11 73 6 o Ljava/lang/Object;
14 73 7 empty Z
15 73 8 isHolder Z
19 25 9 err Ljava/lang/Throwable;
29 46 9 consumerIndexHolder Lio/reactivex/internal/operators/flowable/FlowableWindowTimed$WindowExactBoundedSubscriber$ConsumerIndexHolder;
35 46 10 r J
48 73 9 c J
53 72 11 r J
61 66 13 tm Lio/reactivex/disposables/Disposable;
65 66 14 task Lio/reactivex/disposables/Disposable;
static boolean access$0(io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber);
descriptor: (Lio/reactivex/internal/operators/flowable/FlowableWindowTimed$WindowExactBoundedSubscriber;)Z
flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.cancelled:Z
ireturn
LocalVariableTable:
Start End Slot Name Signature
static io.reactivex.internal.fuseable.SimplePlainQueue access$1(io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber);
descriptor: (Lio/reactivex/internal/operators/flowable/FlowableWindowTimed$WindowExactBoundedSubscriber;)Lio/reactivex/internal/fuseable/SimplePlainQueue;
flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber.queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
areturn
LocalVariableTable:
Start End Slot Name Signature
}
Signature: <T:Ljava/lang/Object;>Lio/reactivex/internal/subscribers/QueueDrainSubscriber<TT;Ljava/lang/Object;Lio/reactivex/Flowable<TT;>;>;Lorg/reactivestreams/Subscription;
SourceFile: "FlowableWindowTimed.java"
NestHost: io.reactivex.internal.operators.flowable.FlowableWindowTimed
InnerClasses:
public abstract Worker = io.reactivex.Scheduler$Worker of io.reactivex.Scheduler
final WindowExactBoundedSubscriber = io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber of io.reactivex.internal.operators.flowable.FlowableWindowTimed
final ConsumerIndexHolder = io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber$ConsumerIndexHolder of io.reactivex.internal.operators.flowable.FlowableWindowTimed$WindowExactBoundedSubscriber