public final class io.reactivex.internal.operators.single.SingleFromCallable<T> extends io.reactivex.Single<T>
minor version: 0
major version: 59
flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
this_class: io.reactivex.internal.operators.single.SingleFromCallable
super_class: io.reactivex.Single
{
final java.util.concurrent.Callable<? extends T> callable;
descriptor: Ljava/util/concurrent/Callable;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/concurrent/Callable<+TT;>;
public void <init>(java.util.concurrent.Callable<? extends T>);
descriptor: (Ljava/util/concurrent/Callable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial io.reactivex.Single.<init>:()V
1: aload 0
aload 1
putfield io.reactivex.internal.operators.single.SingleFromCallable.callable:Ljava/util/concurrent/Callable;
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactivex/internal/operators/single/SingleFromCallable<TT;>;
0 3 1 callable Ljava/util/concurrent/Callable<+TT;>;
Signature: (Ljava/util/concurrent/Callable<+TT;>;)V
MethodParameters:
Name Flags
callable
protected void subscribeActual(io.reactivex.SingleObserver<? super T>);
descriptor: (Lio/reactivex/SingleObserver;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=5, args_size=2
start local 0 start local 1 0: invokestatic io.reactivex.disposables.Disposables.empty:()Lio/reactivex/disposables/Disposable;
astore 2
start local 2 1: aload 1
aload 2
invokeinterface io.reactivex.SingleObserver.onSubscribe:(Lio/reactivex/disposables/Disposable;)V
2: aload 2
invokeinterface io.reactivex.disposables.Disposable.isDisposed:()Z
ifeq 4
3: return
4: StackMap locals: io.reactivex.disposables.Disposable
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.single.SingleFromCallable.callable:Ljava/util/concurrent/Callable;
invokeinterface java.util.concurrent.Callable.call:()Ljava/lang/Object;
ldc "The callable returned a null value"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
astore 3
start local 3 5: goto 13
end local 3 StackMap locals:
StackMap stack: java.lang.Throwable
6: astore 4
start local 4 7: aload 4
invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
8: aload 2
invokeinterface io.reactivex.disposables.Disposable.isDisposed:()Z
ifne 11
9: aload 1
aload 4
invokeinterface io.reactivex.SingleObserver.onError:(Ljava/lang/Throwable;)V
10: goto 12
11: StackMap locals: io.reactivex.internal.operators.single.SingleFromCallable io.reactivex.SingleObserver io.reactivex.disposables.Disposable top java.lang.Throwable
StackMap stack:
aload 4
invokestatic io.reactivex.plugins.RxJavaPlugins.onError:(Ljava/lang/Throwable;)V
12: StackMap locals:
StackMap stack:
return
end local 4 start local 3 13: StackMap locals: io.reactivex.internal.operators.single.SingleFromCallable io.reactivex.SingleObserver io.reactivex.disposables.Disposable java.lang.Object
StackMap stack:
aload 2
invokeinterface io.reactivex.disposables.Disposable.isDisposed:()Z
ifne 15
14: aload 1
aload 3
invokeinterface io.reactivex.SingleObserver.onSuccess:(Ljava/lang/Object;)V
15: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Lio/reactivex/internal/operators/single/SingleFromCallable<TT;>;
0 16 1 observer Lio/reactivex/SingleObserver<-TT;>;
1 16 2 d Lio/reactivex/disposables/Disposable;
5 6 3 value TT;
13 16 3 value TT;
7 13 4 ex Ljava/lang/Throwable;
Exception table:
from to target type
4 5 6 Class java.lang.Throwable
Signature: (Lio/reactivex/SingleObserver<-TT;>;)V
MethodParameters:
Name Flags
observer
}
Signature: <T:Ljava/lang/Object;>Lio/reactivex/Single<TT;>;
SourceFile: "SingleFromCallable.java"