public final class io.reactivex.internal.subscribers.BoundedSubscriber<T> extends java.util.concurrent.atomic.AtomicReference<org.reactivestreams.Subscription> implements io.reactivex.FlowableSubscriber<T>, org.reactivestreams.Subscription, io.reactivex.disposables.Disposable, io.reactivex.observers.LambdaConsumerIntrospection
minor version: 0
major version: 59
flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
this_class: io.reactivex.internal.subscribers.BoundedSubscriber
super_class: java.util.concurrent.atomic.AtomicReference
{
private static final long serialVersionUID;
descriptor: J
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: -7251123623727029452
final io.reactivex.functions.Consumer<? super T> onNext;
descriptor: Lio/reactivex/functions/Consumer;
flags: (0x0010) ACC_FINAL
Signature: Lio/reactivex/functions/Consumer<-TT;>;
final io.reactivex.functions.Consumer<? super java.lang.Throwable> onError;
descriptor: Lio/reactivex/functions/Consumer;
flags: (0x0010) ACC_FINAL
Signature: Lio/reactivex/functions/Consumer<-Ljava/lang/Throwable;>;
final io.reactivex.functions.Action onComplete;
descriptor: Lio/reactivex/functions/Action;
flags: (0x0010) ACC_FINAL
final io.reactivex.functions.Consumer<? super org.reactivestreams.Subscription> onSubscribe;
descriptor: Lio/reactivex/functions/Consumer;
flags: (0x0010) ACC_FINAL
Signature: Lio/reactivex/functions/Consumer<-Lorg/reactivestreams/Subscription;>;
final int bufferSize;
descriptor: I
flags: (0x0010) ACC_FINAL
int consumed;
descriptor: I
flags: (0x0000)
final int limit;
descriptor: I
flags: (0x0010) ACC_FINAL
public void <init>(io.reactivex.functions.Consumer<? super T>, io.reactivex.functions.Consumer<? super java.lang.Throwable>, io.reactivex.functions.Action, io.reactivex.functions.Consumer<? super org.reactivestreams.Subscription>, );
descriptor: (Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;Lio/reactivex/functions/Consumer;I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=6, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
invokespecial java.util.concurrent.atomic.AtomicReference.<init>:()V
1: aload 0
aload 1
putfield io.reactivex.internal.subscribers.BoundedSubscriber.onNext:Lio/reactivex/functions/Consumer;
2: aload 0
aload 2
putfield io.reactivex.internal.subscribers.BoundedSubscriber.onError:Lio/reactivex/functions/Consumer;
3: aload 0
aload 3
putfield io.reactivex.internal.subscribers.BoundedSubscriber.onComplete:Lio/reactivex/functions/Action;
4: aload 0
aload 4
putfield io.reactivex.internal.subscribers.BoundedSubscriber.onSubscribe:Lio/reactivex/functions/Consumer;
5: aload 0
iload 5
putfield io.reactivex.internal.subscribers.BoundedSubscriber.bufferSize:I
6: aload 0
iload 5
iload 5
iconst_2
ishr
isub
putfield io.reactivex.internal.subscribers.BoundedSubscriber.limit:I
7: return
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/reactivex/internal/subscribers/BoundedSubscriber<TT;>;
0 8 1 onNext Lio/reactivex/functions/Consumer<-TT;>;
0 8 2 onError Lio/reactivex/functions/Consumer<-Ljava/lang/Throwable;>;
0 8 3 onComplete Lio/reactivex/functions/Action;
0 8 4 onSubscribe Lio/reactivex/functions/Consumer<-Lorg/reactivestreams/Subscription;>;
0 8 5 bufferSize I
Signature: (Lio/reactivex/functions/Consumer<-TT;>;Lio/reactivex/functions/Consumer<-Ljava/lang/Throwable;>;Lio/reactivex/functions/Action;Lio/reactivex/functions/Consumer<-Lorg/reactivestreams/Subscription;>;I)V
MethodParameters:
Name Flags
onNext
onError
onComplete
onSubscribe
bufferSize
public void onSubscribe(org.reactivestreams.Subscription);
descriptor: (Lorg/reactivestreams/Subscription;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic io.reactivex.internal.subscriptions.SubscriptionHelper.setOnce:(Ljava/util/concurrent/atomic/AtomicReference;Lorg/reactivestreams/Subscription;)Z
ifeq 7
1: aload 0
getfield io.reactivex.internal.subscribers.BoundedSubscriber.onSubscribe:Lio/reactivex/functions/Consumer;
aload 0
invokeinterface io.reactivex.functions.Consumer.accept:(Ljava/lang/Object;)V
2: goto 7
StackMap locals:
StackMap stack: java.lang.Throwable
3: astore 2
start local 2 4: aload 2
invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
5: aload 1
invokeinterface org.reactivestreams.Subscription.cancel:()V
6: aload 0
aload 2
invokevirtual io.reactivex.internal.subscribers.BoundedSubscriber.onError:(Ljava/lang/Throwable;)V
end local 2 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/BoundedSubscriber<TT;>;
0 8 1 s Lorg/reactivestreams/Subscription;
4 7 2 e Ljava/lang/Throwable;
Exception table:
from to target type
1 2 3 Class java.lang.Throwable
MethodParameters:
Name Flags
s
public void onNext();
descriptor: (Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.reactivex.internal.subscribers.BoundedSubscriber.isDisposed:()Z
ifne 13
1: aload 0
getfield io.reactivex.internal.subscribers.BoundedSubscriber.onNext:Lio/reactivex/functions/Consumer;
aload 1
invokeinterface io.reactivex.functions.Consumer.accept:(Ljava/lang/Object;)V
2: aload 0
getfield io.reactivex.internal.subscribers.BoundedSubscriber.consumed:I
iconst_1
iadd
istore 2
start local 2 3: iload 2
aload 0
getfield io.reactivex.internal.subscribers.BoundedSubscriber.limit:I
if_icmpne 7
4: aload 0
iconst_0
putfield io.reactivex.internal.subscribers.BoundedSubscriber.consumed:I
5: aload 0
invokevirtual io.reactivex.internal.subscribers.BoundedSubscriber.get:()Ljava/lang/Object;
checkcast org.reactivestreams.Subscription
aload 0
getfield io.reactivex.internal.subscribers.BoundedSubscriber.limit:I
i2l
invokeinterface org.reactivestreams.Subscription.request:(J)V
6: goto 13
7: StackMap locals: int
StackMap stack:
aload 0
iload 2
putfield io.reactivex.internal.subscribers.BoundedSubscriber.consumed:I
end local 2 8: goto 13
StackMap locals: io.reactivex.internal.subscribers.BoundedSubscriber java.lang.Object
StackMap stack: java.lang.Throwable
9: astore 2
start local 2 10: aload 2
invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
11: aload 0
invokevirtual io.reactivex.internal.subscribers.BoundedSubscriber.get:()Ljava/lang/Object;
checkcast org.reactivestreams.Subscription
invokeinterface org.reactivestreams.Subscription.cancel:()V
12: aload 0
aload 2
invokevirtual io.reactivex.internal.subscribers.BoundedSubscriber.onError:(Ljava/lang/Throwable;)V
end local 2 13: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lio/reactivex/internal/subscribers/BoundedSubscriber<TT;>;
0 14 1 t TT;
3 8 2 c I
10 13 2 e Ljava/lang/Throwable;
Exception table:
from to target type
1 8 9 Class java.lang.Throwable
Signature: (TT;)V
MethodParameters:
Name Flags
t
public void onError(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.reactivex.internal.subscribers.BoundedSubscriber.get:()Ljava/lang/Object;
getstatic io.reactivex.internal.subscriptions.SubscriptionHelper.CANCELLED:Lio/reactivex/internal/subscriptions/SubscriptionHelper;
if_acmpeq 8
1: aload 0
getstatic io.reactivex.internal.subscriptions.SubscriptionHelper.CANCELLED:Lio/reactivex/internal/subscriptions/SubscriptionHelper;
invokevirtual io.reactivex.internal.subscribers.BoundedSubscriber.lazySet:(Ljava/lang/Object;)V
2: aload 0
getfield io.reactivex.internal.subscribers.BoundedSubscriber.onError:Lio/reactivex/functions/Consumer;
aload 1
invokeinterface io.reactivex.functions.Consumer.accept:(Ljava/lang/Object;)V
3: goto 9
StackMap locals:
StackMap stack: java.lang.Throwable
4: astore 2
start local 2 5: aload 2
invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
6: new io.reactivex.exceptions.CompositeException
dup
iconst_2
anewarray java.lang.Throwable
dup
iconst_0
aload 1
aastore
dup
iconst_1
aload 2
aastore
invokespecial io.reactivex.exceptions.CompositeException.<init>:([Ljava/lang/Throwable;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onError:(Ljava/lang/Throwable;)V
end local 2 7: goto 9
8: StackMap locals:
StackMap stack:
aload 1
invokestatic io.reactivex.plugins.RxJavaPlugins.onError:(Ljava/lang/Throwable;)V
9: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/reactivex/internal/subscribers/BoundedSubscriber<TT;>;
0 10 1 t Ljava/lang/Throwable;
5 7 2 e Ljava/lang/Throwable;
Exception table:
from to target type
2 3 4 Class java.lang.Throwable
MethodParameters:
Name Flags
t
public void onComplete();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
invokevirtual io.reactivex.internal.subscribers.BoundedSubscriber.get:()Ljava/lang/Object;
getstatic io.reactivex.internal.subscriptions.SubscriptionHelper.CANCELLED:Lio/reactivex/internal/subscriptions/SubscriptionHelper;
if_acmpeq 7
1: aload 0
getstatic io.reactivex.internal.subscriptions.SubscriptionHelper.CANCELLED:Lio/reactivex/internal/subscriptions/SubscriptionHelper;
invokevirtual io.reactivex.internal.subscribers.BoundedSubscriber.lazySet:(Ljava/lang/Object;)V
2: aload 0
getfield io.reactivex.internal.subscribers.BoundedSubscriber.onComplete:Lio/reactivex/functions/Action;
invokeinterface io.reactivex.functions.Action.run:()V
3: goto 7
StackMap locals:
StackMap stack: java.lang.Throwable
4: astore 1
start local 1 5: aload 1
invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
6: aload 1
invokestatic io.reactivex.plugins.RxJavaPlugins.onError:(Ljava/lang/Throwable;)V
end local 1 7: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/reactivex/internal/subscribers/BoundedSubscriber<TT;>;
5 7 1 e Ljava/lang/Throwable;
Exception table:
from to target type
2 3 4 Class java.lang.Throwable
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.subscribers.BoundedSubscriber.cancel:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/internal/subscribers/BoundedSubscriber<TT;>;
public boolean isDisposed();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.reactivex.internal.subscribers.BoundedSubscriber.get:()Ljava/lang/Object;
getstatic io.reactivex.internal.subscriptions.SubscriptionHelper.CANCELLED:Lio/reactivex/internal/subscriptions/SubscriptionHelper;
if_acmpne 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/internal/subscribers/BoundedSubscriber<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
invokevirtual io.reactivex.internal.subscribers.BoundedSubscriber.get:()Ljava/lang/Object;
checkcast org.reactivestreams.Subscription
lload 1
invokeinterface org.reactivestreams.Subscription.request:(J)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/internal/subscribers/BoundedSubscriber<TT;>;
0 2 1 n J
MethodParameters:
Name Flags
n
public void cancel();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokestatic io.reactivex.internal.subscriptions.SubscriptionHelper.cancel:(Ljava/util/concurrent/atomic/AtomicReference;)Z
pop
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/internal/subscribers/BoundedSubscriber<TT;>;
public boolean hasCustomOnError();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield io.reactivex.internal.subscribers.BoundedSubscriber.onError:Lio/reactivex/functions/Consumer;
getstatic io.reactivex.internal.functions.Functions.ON_ERROR_MISSING:Lio/reactivex/functions/Consumer;
if_acmpeq 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/internal/subscribers/BoundedSubscriber<TT;>;
}
Signature: <T:Ljava/lang/Object;>Ljava/util/concurrent/atomic/AtomicReference<Lorg/reactivestreams/Subscription;>;Lio/reactivex/FlowableSubscriber<TT;>;Lorg/reactivestreams/Subscription;Lio/reactivex/disposables/Disposable;Lio/reactivex/observers/LambdaConsumerIntrospection;
SourceFile: "BoundedSubscriber.java"