final class io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber<T, U extends java.util.Collection<? super T>, B> extends io.reactivex.internal.subscribers.QueueDrainSubscriber<T, U, U> implements io.reactivex.FlowableSubscriber<T>, org.reactivestreams.Subscription, io.reactivex.disposables.Disposable
minor version: 0
major version: 59
flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
this_class: io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber
super_class: io.reactivex.internal.subscribers.QueueDrainSubscriber
{
final java.util.concurrent.Callable<U> bufferSupplier;
descriptor: Ljava/util/concurrent/Callable;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/concurrent/Callable<TU;>;
final org.reactivestreams.Publisher<B> boundary;
descriptor: Lorg/reactivestreams/Publisher;
flags: (0x0010) ACC_FINAL
Signature: Lorg/reactivestreams/Publisher<TB;>;
org.reactivestreams.Subscription upstream;
descriptor: Lorg/reactivestreams/Subscription;
flags: (0x0000)
io.reactivex.disposables.Disposable other;
descriptor: Lio/reactivex/disposables/Disposable;
flags: (0x0000)
U buffer;
descriptor: Ljava/util/Collection;
flags: (0x0000)
Signature: TU;
void <init>(org.reactivestreams.Subscriber<? super U>, java.util.concurrent.Callable<U>, org.reactivestreams.Publisher<B>);
descriptor: (Lorg/reactivestreams/Subscriber;Ljava/util/concurrent/Callable;Lorg/reactivestreams/Publisher;)V
flags: (0x0000)
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 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
aload 2
putfield io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.bufferSupplier:Ljava/util/concurrent/Callable;
2: aload 0
aload 3
putfield io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.boundary:Lorg/reactivestreams/Publisher;
3: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/reactivex/internal/operators/flowable/FlowableBufferExactBoundary$BufferExactBoundarySubscriber<TT;TU;TB;>;
0 4 1 actual Lorg/reactivestreams/Subscriber<-TU;>;
0 4 2 bufferSupplier Ljava/util/concurrent/Callable<TU;>;
0 4 3 boundary Lorg/reactivestreams/Publisher<TB;>;
Signature: (Lorg/reactivestreams/Subscriber<-TU;>;Ljava/util/concurrent/Callable<TU;>;Lorg/reactivestreams/Publisher<TB;>;)V
MethodParameters:
Name Flags
actual
bufferSupplier
boundary
public void onSubscribe(org.reactivestreams.Subscription);
descriptor: (Lorg/reactivestreams/Subscription;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.upstream:Lorg/reactivestreams/Subscription;
aload 1
invokestatic io.reactivex.internal.subscriptions.SubscriptionHelper.validate:(Lorg/reactivestreams/Subscription;Lorg/reactivestreams/Subscription;)Z
ifne 2
1: return
2: StackMap locals:
StackMap stack:
aload 0
aload 1
putfield io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.upstream:Lorg/reactivestreams/Subscription;
3: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.bufferSupplier:Ljava/util/concurrent/Callable;
invokeinterface java.util.concurrent.Callable.call:()Ljava/lang/Object;
checkcast java.util.Collection
ldc "The buffer supplied is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast java.util.Collection
astore 2
start local 2 4: goto 11
end local 2 StackMap locals:
StackMap stack: java.lang.Throwable
5: astore 3
start local 3 6: aload 3
invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
7: aload 0
iconst_1
putfield io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.cancelled:Z
8: aload 1
invokeinterface org.reactivestreams.Subscription.cancel:()V
9: aload 3
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.downstream:Lorg/reactivestreams/Subscriber;
invokestatic io.reactivex.internal.subscriptions.EmptySubscription.error:(Ljava/lang/Throwable;Lorg/reactivestreams/Subscriber;)V
10: return
end local 3 start local 2 11: StackMap locals: java.util.Collection
StackMap stack:
aload 0
aload 2
putfield io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.buffer:Ljava/util/Collection;
12: new io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferBoundarySubscriber
dup
aload 0
invokespecial io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferBoundarySubscriber.<init>:(Lio/reactivex/internal/operators/flowable/FlowableBufferExactBoundary$BufferExactBoundarySubscriber;)V
astore 3
start local 3 13: aload 0
aload 3
putfield io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.other:Lio/reactivex/disposables/Disposable;
14: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.downstream:Lorg/reactivestreams/Subscriber;
aload 0
invokeinterface org.reactivestreams.Subscriber.onSubscribe:(Lorg/reactivestreams/Subscription;)V
15: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.cancelled:Z
ifne 18
16: aload 1
ldc 9223372036854775807
invokeinterface org.reactivestreams.Subscription.request:(J)V
17: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.boundary:Lorg/reactivestreams/Publisher;
aload 3
invokeinterface org.reactivestreams.Publisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
18: StackMap locals: io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferBoundarySubscriber
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 19 0 this Lio/reactivex/internal/operators/flowable/FlowableBufferExactBoundary$BufferExactBoundarySubscriber<TT;TU;TB;>;
0 19 1 s Lorg/reactivestreams/Subscription;
4 5 2 b TU;
11 19 2 b TU;
6 11 3 e Ljava/lang/Throwable;
13 19 3 bs Lio/reactivex/internal/operators/flowable/FlowableBufferExactBoundary$BufferBoundarySubscriber<TT;TU;TB;>;
Exception table:
from to target type
3 4 5 Class java.lang.Throwable
MethodParameters:
Name Flags
s
public void onNext();
descriptor: (Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=2
start local 0 start local 1 0: aload 0
dup
astore 2
monitorenter
1: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.buffer:Ljava/util/Collection;
astore 3
start local 3 2: aload 3
ifnonnull 5
3: aload 2
monitorexit
4: return
5: StackMap locals: io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber java.util.Collection
StackMap stack:
aload 3
aload 1
invokeinterface java.util.Collection.add:(Ljava/lang/Object;)Z
pop
end local 3 6: aload 2
monitorexit
7: goto 10
StackMap locals: io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber java.lang.Object io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber
StackMap stack: java.lang.Throwable
8: aload 2
monitorexit
9: athrow
10: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lio/reactivex/internal/operators/flowable/FlowableBufferExactBoundary$BufferExactBoundarySubscriber<TT;TU;TB;>;
0 11 1 t TT;
2 6 3 b TU;
Exception table:
from to target type
1 4 8 any
5 7 8 any
8 9 8 any
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
invokevirtual io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.cancel:()V
1: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.downstream:Lorg/reactivestreams/Subscriber;
aload 1
invokeinterface org.reactivestreams.Subscriber.onError:(Ljava/lang/Throwable;)V
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactivex/internal/operators/flowable/FlowableBufferExactBoundary$BufferExactBoundarySubscriber<TT;TU;TB;>;
0 3 1 t Ljava/lang/Throwable;
MethodParameters:
Name Flags
t
public void onComplete();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=3, args_size=1
start local 0 0: aload 0
dup
astore 2
monitorenter
1: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.buffer:Ljava/util/Collection;
astore 1
start local 1 2: aload 1
ifnonnull 5
3: aload 2
monitorexit
4: return
5: StackMap locals: java.util.Collection io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber
StackMap stack:
aload 0
aconst_null
putfield io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.buffer:Ljava/util/Collection;
6: aload 2
monitorexit
7: goto 10
end local 1 StackMap locals: io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber top io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber
StackMap stack: java.lang.Throwable
8: aload 2
monitorexit
9: athrow
start local 1 10: StackMap locals: io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber java.util.Collection
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
aload 1
invokeinterface io.reactivex.internal.fuseable.SimplePlainQueue.offer:(Ljava/lang/Object;)Z
pop
11: aload 0
iconst_1
putfield io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.done:Z
12: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.enter:()Z
ifeq 14
13: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
aload 0
getfield io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.downstream:Lorg/reactivestreams/Subscriber;
iconst_0
aload 0
aload 0
invokestatic io.reactivex.internal.util.QueueDrainHelper.drainMaxLoop:(Lio/reactivex/internal/fuseable/SimplePlainQueue;Lorg/reactivestreams/Subscriber;ZLio/reactivex/disposables/Disposable;Lio/reactivex/internal/util/QueueDrain;)V
14: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lio/reactivex/internal/operators/flowable/FlowableBufferExactBoundary$BufferExactBoundarySubscriber<TT;TU;TB;>;
2 8 1 b TU;
10 15 1 b TU;
Exception table:
from to target type
1 4 8 any
5 7 8 any
8 9 8 any
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.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.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/FlowableBufferExactBoundary$BufferExactBoundarySubscriber<TT;TU;TB;>;
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
getfield io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.cancelled:Z
ifne 6
1: aload 0
iconst_1
putfield io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.cancelled:Z
2: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.other:Lio/reactivex/disposables/Disposable;
invokeinterface io.reactivex.disposables.Disposable.dispose:()V
3: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.upstream:Lorg/reactivestreams/Subscription;
invokeinterface org.reactivestreams.Subscription.cancel:()V
4: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.enter:()Z
ifeq 6
5: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
invokeinterface io.reactivex.internal.fuseable.SimplePlainQueue.clear:()V
6: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/reactivex/internal/operators/flowable/FlowableBufferExactBoundary$BufferExactBoundarySubscriber<TT;TU;TB;>;
void next();
descriptor: ()V
flags: (0x0000)
Code:
stack=4, locals=4, args_size=1
start local 0 0: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.bufferSupplier:Ljava/util/concurrent/Callable;
invokeinterface java.util.concurrent.Callable.call:()Ljava/lang/Object;
checkcast java.util.Collection
ldc "The buffer supplied is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast java.util.Collection
astore 1
start local 1 1: goto 7
end local 1 StackMap locals:
StackMap stack: java.lang.Throwable
2: astore 2
start local 2 3: aload 2
invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
4: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.cancel:()V
5: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.downstream:Lorg/reactivestreams/Subscriber;
aload 2
invokeinterface org.reactivestreams.Subscriber.onError:(Ljava/lang/Throwable;)V
6: return
end local 2 start local 1 7: StackMap locals: java.util.Collection
StackMap stack:
aload 0
dup
astore 3
monitorenter
8: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.buffer:Ljava/util/Collection;
astore 2
start local 2 9: aload 2
ifnonnull 12
10: aload 3
monitorexit
11: return
12: StackMap locals: java.util.Collection io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber
StackMap stack:
aload 0
aload 1
putfield io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.buffer:Ljava/util/Collection;
13: aload 3
monitorexit
14: goto 17
end local 2 StackMap locals: io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber java.util.Collection top io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber
StackMap stack: java.lang.Throwable
15: aload 3
monitorexit
16: athrow
start local 2 17: StackMap locals: io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber java.util.Collection java.util.Collection
StackMap stack:
aload 0
aload 2
iconst_0
aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.fastPathEmitMax:(Ljava/lang/Object;ZLio/reactivex/disposables/Disposable;)V
18: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 19 0 this Lio/reactivex/internal/operators/flowable/FlowableBufferExactBoundary$BufferExactBoundarySubscriber<TT;TU;TB;>;
1 2 1 next TU;
7 19 1 next TU;
3 7 2 e Ljava/lang/Throwable;
9 15 2 b TU;
17 19 2 b TU;
Exception table:
from to target type
0 1 2 Class java.lang.Throwable
8 11 15 any
12 14 15 any
15 16 15 any
public void dispose();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.cancel:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/internal/operators/flowable/FlowableBufferExactBoundary$BufferExactBoundarySubscriber<TT;TU;TB;>;
public boolean isDisposed();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.cancelled:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/internal/operators/flowable/FlowableBufferExactBoundary$BufferExactBoundarySubscriber<TT;TU;TB;>;
public boolean accept(org.reactivestreams.Subscriber<? super U>, );
descriptor: (Lorg/reactivestreams/Subscriber;Ljava/util/Collection;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.downstream:Lorg/reactivestreams/Subscriber;
aload 2
invokeinterface org.reactivestreams.Subscriber.onNext:(Ljava/lang/Object;)V
1: iconst_1
ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/internal/operators/flowable/FlowableBufferExactBoundary$BufferExactBoundarySubscriber<TT;TU;TB;>;
0 2 1 a Lorg/reactivestreams/Subscriber<-TU;>;
0 2 2 v TU;
Signature: (Lorg/reactivestreams/Subscriber<-TU;>;TU;)Z
MethodParameters:
Name Flags
a
v
public boolean accept(org.reactivestreams.Subscriber, java.lang.Object);
descriptor: (Lorg/reactivestreams/Subscriber;Ljava/lang/Object;)Z
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
0: aload 0
aload 1
checkcast org.reactivestreams.Subscriber
aload 2
checkcast java.util.Collection
invokevirtual io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber.accept:(Lorg/reactivestreams/Subscriber;Ljava/util/Collection;)Z
ireturn
LocalVariableTable:
Start End Slot Name Signature
}
Signature: <T:Ljava/lang/Object;U::Ljava/util/Collection<-TT;>;B:Ljava/lang/Object;>Lio/reactivex/internal/subscribers/QueueDrainSubscriber<TT;TU;TU;>;Lio/reactivex/FlowableSubscriber<TT;>;Lorg/reactivestreams/Subscription;Lio/reactivex/disposables/Disposable;
SourceFile: "FlowableBufferExactBoundary.java"
NestHost: io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary
InnerClasses:
final BufferBoundarySubscriber = io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferBoundarySubscriber of io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary
final BufferExactBoundarySubscriber = io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary$BufferExactBoundarySubscriber of io.reactivex.internal.operators.flowable.FlowableBufferExactBoundary