public abstract class io.reactivex.internal.subscribers.BlockingBaseSubscriber<T> extends java.util.concurrent.CountDownLatch implements io.reactivex.FlowableSubscriber<T>
minor version: 0
major version: 59
flags: flags: (0x0421) ACC_PUBLIC, ACC_SUPER, ACC_ABSTRACT
this_class: io.reactivex.internal.subscribers.BlockingBaseSubscriber
super_class: java.util.concurrent.CountDownLatch
{
T value;
descriptor: Ljava/lang/Object;
flags: (0x0000)
Signature: TT;
java.lang.Throwable error;
descriptor: Ljava/lang/Throwable;
flags: (0x0000)
org.reactivestreams.Subscription upstream;
descriptor: Lorg/reactivestreams/Subscription;
flags: (0x0000)
volatile boolean cancelled;
descriptor: Z
flags: (0x0040) ACC_VOLATILE
public void <init>();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
iconst_1
invokespecial java.util.concurrent.CountDownLatch.<init>:(I)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/internal/subscribers/BlockingBaseSubscriber<TT;>;
public final void onSubscribe(org.reactivestreams.Subscription);
descriptor: (Lorg/reactivestreams/Subscription;)V
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.reactivex.internal.subscribers.BlockingBaseSubscriber.upstream:Lorg/reactivestreams/Subscription;
aload 1
invokestatic io.reactivex.internal.subscriptions.SubscriptionHelper.validate:(Lorg/reactivestreams/Subscription;Lorg/reactivestreams/Subscription;)Z
ifeq 7
1: aload 0
aload 1
putfield io.reactivex.internal.subscribers.BlockingBaseSubscriber.upstream:Lorg/reactivestreams/Subscription;
2: aload 0
getfield io.reactivex.internal.subscribers.BlockingBaseSubscriber.cancelled:Z
ifne 7
3: aload 1
ldc 9223372036854775807
invokeinterface org.reactivestreams.Subscription.request:(J)V
4: aload 0
getfield io.reactivex.internal.subscribers.BlockingBaseSubscriber.cancelled:Z
ifeq 7
5: aload 0
getstatic io.reactivex.internal.subscriptions.SubscriptionHelper.CANCELLED:Lio/reactivex/internal/subscriptions/SubscriptionHelper;
putfield io.reactivex.internal.subscribers.BlockingBaseSubscriber.upstream:Lorg/reactivestreams/Subscription;
6: aload 1
invokeinterface org.reactivestreams.Subscription.cancel:()V
7: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/reactivex/internal/subscribers/BlockingBaseSubscriber<TT;>;
0 8 1 s Lorg/reactivestreams/Subscription;
MethodParameters:
Name Flags
s
public final void onComplete();
descriptor: ()V
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.reactivex.internal.subscribers.BlockingBaseSubscriber.countDown:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/internal/subscribers/BlockingBaseSubscriber<TT;>;
public final T blockingGet();
descriptor: ()Ljava/lang/Object;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=3, args_size=1
start local 0 0: aload 0
invokevirtual io.reactivex.internal.subscribers.BlockingBaseSubscriber.getCount:()J
lconst_0
lcmp
ifeq 10
1: invokestatic io.reactivex.internal.util.BlockingHelper.verifyNonBlocking:()V
2: aload 0
invokevirtual io.reactivex.internal.subscribers.BlockingBaseSubscriber.await:()V
3: goto 10
StackMap locals:
StackMap stack: java.lang.InterruptedException
4: astore 1
start local 1 5: aload 0
getfield io.reactivex.internal.subscribers.BlockingBaseSubscriber.upstream:Lorg/reactivestreams/Subscription;
astore 2
start local 2 6: aload 0
getstatic io.reactivex.internal.subscriptions.SubscriptionHelper.CANCELLED:Lio/reactivex/internal/subscriptions/SubscriptionHelper;
putfield io.reactivex.internal.subscribers.BlockingBaseSubscriber.upstream:Lorg/reactivestreams/Subscription;
7: aload 2
ifnull 9
8: aload 2
invokeinterface org.reactivestreams.Subscription.cancel:()V
9: StackMap locals: java.lang.InterruptedException org.reactivestreams.Subscription
StackMap stack:
aload 1
invokestatic io.reactivex.internal.util.ExceptionHelper.wrapOrThrow:(Ljava/lang/Throwable;)Ljava/lang/RuntimeException;
athrow
end local 2 end local 1 10: StackMap locals:
StackMap stack:
aload 0
getfield io.reactivex.internal.subscribers.BlockingBaseSubscriber.error:Ljava/lang/Throwable;
astore 1
start local 1 11: aload 1
ifnull 13
12: aload 1
invokestatic io.reactivex.internal.util.ExceptionHelper.wrapOrThrow:(Ljava/lang/Throwable;)Ljava/lang/RuntimeException;
athrow
13: StackMap locals: java.lang.Throwable
StackMap stack:
aload 0
getfield io.reactivex.internal.subscribers.BlockingBaseSubscriber.value:Ljava/lang/Object;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lio/reactivex/internal/subscribers/BlockingBaseSubscriber<TT;>;
5 10 1 ex Ljava/lang/InterruptedException;
6 10 2 s Lorg/reactivestreams/Subscription;
11 14 1 e Ljava/lang/Throwable;
Exception table:
from to target type
1 3 4 Class java.lang.InterruptedException
Signature: ()TT;
}
Signature: <T:Ljava/lang/Object;>Ljava/util/concurrent/CountDownLatch;Lio/reactivex/FlowableSubscriber<TT;>;
SourceFile: "BlockingBaseSubscriber.java"