public abstract class io.reactivex.Single<T> implements io.reactivex.SingleSource<T>
minor version: 0
major version: 59
flags: flags: (0x0421) ACC_PUBLIC, ACC_SUPER, ACC_ABSTRACT
this_class: io.reactivex.Single
super_class: java.lang.Object
{
public void <init>();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokespecial java.lang.Object.<init>:()V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
public static <T> io.reactivex.Single<T> amb(java.lang.Iterable<? extends io.reactivex.SingleSource<? extends T>>);
descriptor: (Ljava/lang/Iterable;)Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
ldc "sources is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleAmb
dup
aconst_null
aload 0
invokespecial io.reactivex.internal.operators.single.SingleAmb.<init>:([Lio/reactivex/SingleSource;Ljava/lang/Iterable;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 sources Ljava/lang/Iterable<+Lio/reactivex/SingleSource<+TT;>;>;
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Iterable<+Lio/reactivex/SingleSource<+TT;>;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
sources final
public static <T> io.reactivex.Single<T> ambArray(io.reactivex.SingleSource<? extends T>[]);
descriptor: ([Lio/reactivex/SingleSource;)Lio/reactivex/Single;
flags: (0x0089) ACC_PUBLIC, ACC_STATIC, ACC_VARARGS
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
arraylength
ifne 2
1: invokestatic io.reactivex.internal.operators.single.SingleInternalHelper.emptyThrower:()Ljava/util/concurrent/Callable;
invokestatic io.reactivex.Single.error:(Ljava/util/concurrent/Callable;)Lio/reactivex/Single;
areturn
2: StackMap locals:
StackMap stack:
aload 0
arraylength
iconst_1
if_icmpne 4
3: aload 0
iconst_0
aaload
invokestatic io.reactivex.Single.wrap:(Lio/reactivex/SingleSource;)Lio/reactivex/Single;
areturn
4: StackMap locals:
StackMap stack:
new io.reactivex.internal.operators.single.SingleAmb
dup
aload 0
aconst_null
invokespecial io.reactivex.internal.operators.single.SingleAmb.<init>:([Lio/reactivex/SingleSource;Ljava/lang/Iterable;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 sources [Lio/reactivex/SingleSource;
Signature: <T:Ljava/lang/Object;>([Lio/reactivex/SingleSource<+TT;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
sources final
public static <T> io.reactivex.Flowable<T> concat(java.lang.Iterable<? extends io.reactivex.SingleSource<? extends T>>);
descriptor: (Ljava/lang/Iterable;)Lio/reactivex/Flowable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokestatic io.reactivex.Flowable.fromIterable:(Ljava/lang/Iterable;)Lio/reactivex/Flowable;
invokestatic io.reactivex.Single.concat:(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 sources Ljava/lang/Iterable<+Lio/reactivex/SingleSource<+TT;>;>;
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Iterable<+Lio/reactivex/SingleSource<+TT;>;>;)Lio/reactivex/Flowable<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
sources
public static <T> io.reactivex.Observable<T> concat(io.reactivex.ObservableSource<? extends io.reactivex.SingleSource<? extends T>>);
descriptor: (Lio/reactivex/ObservableSource;)Lio/reactivex/Observable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=1, args_size=1
start local 0 0: aload 0
ldc "sources is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.observable.ObservableConcatMap
dup
aload 0
invokestatic io.reactivex.internal.operators.single.SingleInternalHelper.toObservable:()Lio/reactivex/functions/Function;
iconst_2
getstatic io.reactivex.internal.util.ErrorMode.IMMEDIATE:Lio/reactivex/internal/util/ErrorMode;
invokespecial io.reactivex.internal.operators.observable.ObservableConcatMap.<init>:(Lio/reactivex/ObservableSource;Lio/reactivex/functions/Function;ILio/reactivex/internal/util/ErrorMode;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Observable;)Lio/reactivex/Observable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 sources Lio/reactivex/ObservableSource<+Lio/reactivex/SingleSource<+TT;>;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/ObservableSource<+Lio/reactivex/SingleSource<+TT;>;>;)Lio/reactivex/Observable<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
sources
public static <T> io.reactivex.Flowable<T> concat(org.reactivestreams.Publisher<? extends io.reactivex.SingleSource<? extends T>>);
descriptor: (Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
iconst_2
invokestatic io.reactivex.Single.concat:(Lorg/reactivestreams/Publisher;I)Lio/reactivex/Flowable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 sources Lorg/reactivestreams/Publisher<+Lio/reactivex/SingleSource<+TT;>;>;
Signature: <T:Ljava/lang/Object;>(Lorg/reactivestreams/Publisher<+Lio/reactivex/SingleSource<+TT;>;>;)Lio/reactivex/Flowable<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
sources
public static <T> io.reactivex.Flowable<T> concat(org.reactivestreams.Publisher<? extends io.reactivex.SingleSource<? extends T>>, int);
descriptor: (Lorg/reactivestreams/Publisher;I)Lio/reactivex/Flowable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=2, args_size=2
start local 0 start local 1 0: aload 0
ldc "sources is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: iload 1
ldc "prefetch"
invokestatic io.reactivex.internal.functions.ObjectHelper.verifyPositive:(ILjava/lang/String;)I
pop
2: new io.reactivex.internal.operators.flowable.FlowableConcatMapPublisher
dup
aload 0
invokestatic io.reactivex.internal.operators.single.SingleInternalHelper.toFlowable:()Lio/reactivex/functions/Function;
iload 1
getstatic io.reactivex.internal.util.ErrorMode.IMMEDIATE:Lio/reactivex/internal/util/ErrorMode;
invokespecial io.reactivex.internal.operators.flowable.FlowableConcatMapPublisher.<init>:(Lorg/reactivestreams/Publisher;Lio/reactivex/functions/Function;ILio/reactivex/internal/util/ErrorMode;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Flowable;)Lio/reactivex/Flowable;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 sources Lorg/reactivestreams/Publisher<+Lio/reactivex/SingleSource<+TT;>;>;
0 3 1 prefetch I
Signature: <T:Ljava/lang/Object;>(Lorg/reactivestreams/Publisher<+Lio/reactivex/SingleSource<+TT;>;>;I)Lio/reactivex/Flowable<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
sources
prefetch
public static <T> io.reactivex.Flowable<T> concat(io.reactivex.SingleSource<? extends T>, io.reactivex.SingleSource<? extends T>);
descriptor: (Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;)Lio/reactivex/Flowable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
ldc "source1 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 1
ldc "source2 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: iconst_2
anewarray io.reactivex.SingleSource
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
invokestatic io.reactivex.Flowable.fromArray:([Ljava/lang/Object;)Lio/reactivex/Flowable;
invokestatic io.reactivex.Single.concat:(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 source1 Lio/reactivex/SingleSource<+TT;>;
0 3 1 source2 Lio/reactivex/SingleSource<+TT;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/SingleSource<+TT;>;Lio/reactivex/SingleSource<+TT;>;)Lio/reactivex/Flowable<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
source1
source2
public static <T> io.reactivex.Flowable<T> concat(io.reactivex.SingleSource<? extends T>, io.reactivex.SingleSource<? extends T>, io.reactivex.SingleSource<? extends T>);
descriptor: (Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;)Lio/reactivex/Flowable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
ldc "source1 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 1
ldc "source2 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 2
ldc "source3 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
3: iconst_3
anewarray io.reactivex.SingleSource
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
dup
iconst_2
aload 2
aastore
invokestatic io.reactivex.Flowable.fromArray:([Ljava/lang/Object;)Lio/reactivex/Flowable;
invokestatic io.reactivex.Single.concat:(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 source1 Lio/reactivex/SingleSource<+TT;>;
0 4 1 source2 Lio/reactivex/SingleSource<+TT;>;
0 4 2 source3 Lio/reactivex/SingleSource<+TT;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/SingleSource<+TT;>;Lio/reactivex/SingleSource<+TT;>;Lio/reactivex/SingleSource<+TT;>;)Lio/reactivex/Flowable<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
source1
source2
source3
public static <T> io.reactivex.Flowable<T> concat(io.reactivex.SingleSource<? extends T>, io.reactivex.SingleSource<? extends T>, io.reactivex.SingleSource<? extends T>, io.reactivex.SingleSource<? extends T>);
descriptor: (Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;)Lio/reactivex/Flowable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
ldc "source1 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 1
ldc "source2 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 2
ldc "source3 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
3: aload 3
ldc "source4 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
4: iconst_4
anewarray io.reactivex.SingleSource
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
dup
iconst_2
aload 2
aastore
dup
iconst_3
aload 3
aastore
invokestatic io.reactivex.Flowable.fromArray:([Ljava/lang/Object;)Lio/reactivex/Flowable;
invokestatic io.reactivex.Single.concat:(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 source1 Lio/reactivex/SingleSource<+TT;>;
0 5 1 source2 Lio/reactivex/SingleSource<+TT;>;
0 5 2 source3 Lio/reactivex/SingleSource<+TT;>;
0 5 3 source4 Lio/reactivex/SingleSource<+TT;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/SingleSource<+TT;>;Lio/reactivex/SingleSource<+TT;>;Lio/reactivex/SingleSource<+TT;>;Lio/reactivex/SingleSource<+TT;>;)Lio/reactivex/Flowable<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
source1
source2
source3
source4
public static <T> io.reactivex.Flowable<T> concatArray(io.reactivex.SingleSource<? extends T>[]);
descriptor: ([Lio/reactivex/SingleSource;)Lio/reactivex/Flowable;
flags: (0x0089) ACC_PUBLIC, ACC_STATIC, ACC_VARARGS
Code:
stack=6, locals=1, args_size=1
start local 0 0: new io.reactivex.internal.operators.flowable.FlowableConcatMap
dup
aload 0
invokestatic io.reactivex.Flowable.fromArray:([Ljava/lang/Object;)Lio/reactivex/Flowable;
invokestatic io.reactivex.internal.operators.single.SingleInternalHelper.toFlowable:()Lio/reactivex/functions/Function;
iconst_2
getstatic io.reactivex.internal.util.ErrorMode.BOUNDARY:Lio/reactivex/internal/util/ErrorMode;
invokespecial io.reactivex.internal.operators.flowable.FlowableConcatMap.<init>:(Lio/reactivex/Flowable;Lio/reactivex/functions/Function;ILio/reactivex/internal/util/ErrorMode;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Flowable;)Lio/reactivex/Flowable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 sources [Lio/reactivex/SingleSource;
Signature: <T:Ljava/lang/Object;>([Lio/reactivex/SingleSource<+TT;>;)Lio/reactivex/Flowable<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
sources
public static <T> io.reactivex.Flowable<T> concatArrayEager(io.reactivex.SingleSource<? extends T>[]);
descriptor: ([Lio/reactivex/SingleSource;)Lio/reactivex/Flowable;
flags: (0x0089) ACC_PUBLIC, ACC_STATIC, ACC_VARARGS
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
invokestatic io.reactivex.Flowable.fromArray:([Ljava/lang/Object;)Lio/reactivex/Flowable;
invokestatic io.reactivex.internal.operators.single.SingleInternalHelper.toFlowable:()Lio/reactivex/functions/Function;
invokevirtual io.reactivex.Flowable.concatMapEager:(Lio/reactivex/functions/Function;)Lio/reactivex/Flowable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 sources [Lio/reactivex/SingleSource;
Signature: <T:Ljava/lang/Object;>([Lio/reactivex/SingleSource<+TT;>;)Lio/reactivex/Flowable<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
sources
public static <T> io.reactivex.Flowable<T> concatEager(org.reactivestreams.Publisher<? extends io.reactivex.SingleSource<? extends T>>);
descriptor: (Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
invokestatic io.reactivex.Flowable.fromPublisher:(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable;
invokestatic io.reactivex.internal.operators.single.SingleInternalHelper.toFlowable:()Lio/reactivex/functions/Function;
invokevirtual io.reactivex.Flowable.concatMapEager:(Lio/reactivex/functions/Function;)Lio/reactivex/Flowable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 sources Lorg/reactivestreams/Publisher<+Lio/reactivex/SingleSource<+TT;>;>;
Signature: <T:Ljava/lang/Object;>(Lorg/reactivestreams/Publisher<+Lio/reactivex/SingleSource<+TT;>;>;)Lio/reactivex/Flowable<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
sources
public static <T> io.reactivex.Flowable<T> concatEager(java.lang.Iterable<? extends io.reactivex.SingleSource<? extends T>>);
descriptor: (Ljava/lang/Iterable;)Lio/reactivex/Flowable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
invokestatic io.reactivex.Flowable.fromIterable:(Ljava/lang/Iterable;)Lio/reactivex/Flowable;
invokestatic io.reactivex.internal.operators.single.SingleInternalHelper.toFlowable:()Lio/reactivex/functions/Function;
invokevirtual io.reactivex.Flowable.concatMapEager:(Lio/reactivex/functions/Function;)Lio/reactivex/Flowable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 sources Ljava/lang/Iterable<+Lio/reactivex/SingleSource<+TT;>;>;
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Iterable<+Lio/reactivex/SingleSource<+TT;>;>;)Lio/reactivex/Flowable<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
sources
public static <T> io.reactivex.Single<T> create(io.reactivex.SingleOnSubscribe<T>);
descriptor: (Lio/reactivex/SingleOnSubscribe;)Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ldc "source is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleCreate
dup
aload 0
invokespecial io.reactivex.internal.operators.single.SingleCreate.<init>:(Lio/reactivex/SingleOnSubscribe;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 source Lio/reactivex/SingleOnSubscribe<TT;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/SingleOnSubscribe<TT;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
source
public static <T> io.reactivex.Single<T> defer(java.util.concurrent.Callable<? extends io.reactivex.SingleSource<? extends T>>);
descriptor: (Ljava/util/concurrent/Callable;)Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ldc "singleSupplier is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleDefer
dup
aload 0
invokespecial io.reactivex.internal.operators.single.SingleDefer.<init>:(Ljava/util/concurrent/Callable;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 singleSupplier Ljava/util/concurrent/Callable<+Lio/reactivex/SingleSource<+TT;>;>;
Signature: <T:Ljava/lang/Object;>(Ljava/util/concurrent/Callable<+Lio/reactivex/SingleSource<+TT;>;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
singleSupplier final
public static <T> io.reactivex.Single<T> error(java.util.concurrent.Callable<? extends java.lang.Throwable>);
descriptor: (Ljava/util/concurrent/Callable;)Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ldc "errorSupplier is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleError
dup
aload 0
invokespecial io.reactivex.internal.operators.single.SingleError.<init>:(Ljava/util/concurrent/Callable;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 errorSupplier Ljava/util/concurrent/Callable<+Ljava/lang/Throwable;>;
Signature: <T:Ljava/lang/Object;>(Ljava/util/concurrent/Callable<+Ljava/lang/Throwable;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
errorSupplier final
public static <T> io.reactivex.Single<T> error(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
ldc "exception is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
invokestatic io.reactivex.internal.functions.Functions.justCallable:(Ljava/lang/Object;)Ljava/util/concurrent/Callable;
invokestatic io.reactivex.Single.error:(Ljava/util/concurrent/Callable;)Lio/reactivex/Single;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 exception Ljava/lang/Throwable;
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Throwable;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
exception final
public static <T> io.reactivex.Single<T> fromCallable(java.util.concurrent.Callable<? extends T>);
descriptor: (Ljava/util/concurrent/Callable;)Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ldc "callable is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleFromCallable
dup
aload 0
invokespecial io.reactivex.internal.operators.single.SingleFromCallable.<init>:(Ljava/util/concurrent/Callable;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 callable Ljava/util/concurrent/Callable<+TT;>;
Signature: <T:Ljava/lang/Object;>(Ljava/util/concurrent/Callable<+TT;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
callable final
public static <T> io.reactivex.Single<T> fromFuture(java.util.concurrent.Future<? extends T>);
descriptor: (Ljava/util/concurrent/Future;)Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokestatic io.reactivex.Flowable.fromFuture:(Ljava/util/concurrent/Future;)Lio/reactivex/Flowable;
invokestatic io.reactivex.Single.toSingle:(Lio/reactivex/Flowable;)Lio/reactivex/Single;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 future Ljava/util/concurrent/Future<+TT;>;
Signature: <T:Ljava/lang/Object;>(Ljava/util/concurrent/Future<+TT;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
future
public static <T> io.reactivex.Single<T> fromFuture(java.util.concurrent.Future<? extends T>, long, java.util.concurrent.TimeUnit);
descriptor: (Ljava/util/concurrent/Future;JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 3 0: aload 0
lload 1
aload 3
invokestatic io.reactivex.Flowable.fromFuture:(Ljava/util/concurrent/Future;JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Flowable;
invokestatic io.reactivex.Single.toSingle:(Lio/reactivex/Flowable;)Lio/reactivex/Single;
areturn
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 future Ljava/util/concurrent/Future<+TT;>;
0 1 1 timeout J
0 1 3 unit Ljava/util/concurrent/TimeUnit;
Signature: <T:Ljava/lang/Object;>(Ljava/util/concurrent/Future<+TT;>;JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
future
timeout
unit
public static <T> io.reactivex.Single<T> fromFuture(java.util.concurrent.Future<? extends T>, long, java.util.concurrent.TimeUnit, io.reactivex.Scheduler);
descriptor: (Ljava/util/concurrent/Future;JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=5, args_size=4
start local 0 start local 1 start local 3 start local 4 0: aload 0
lload 1
aload 3
aload 4
invokestatic io.reactivex.Flowable.fromFuture:(Ljava/util/concurrent/Future;JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Flowable;
invokestatic io.reactivex.Single.toSingle:(Lio/reactivex/Flowable;)Lio/reactivex/Single;
areturn
end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 future Ljava/util/concurrent/Future<+TT;>;
0 1 1 timeout J
0 1 3 unit Ljava/util/concurrent/TimeUnit;
0 1 4 scheduler Lio/reactivex/Scheduler;
Signature: <T:Ljava/lang/Object;>(Ljava/util/concurrent/Future<+TT;>;JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "custom")
MethodParameters:
Name Flags
future
timeout
unit
scheduler
public static <T> io.reactivex.Single<T> fromFuture(java.util.concurrent.Future<? extends T>, io.reactivex.Scheduler);
descriptor: (Ljava/util/concurrent/Future;Lio/reactivex/Scheduler;)Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic io.reactivex.Flowable.fromFuture:(Ljava/util/concurrent/Future;Lio/reactivex/Scheduler;)Lio/reactivex/Flowable;
invokestatic io.reactivex.Single.toSingle:(Lio/reactivex/Flowable;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 future Ljava/util/concurrent/Future<+TT;>;
0 1 1 scheduler Lio/reactivex/Scheduler;
Signature: <T:Ljava/lang/Object;>(Ljava/util/concurrent/Future<+TT;>;Lio/reactivex/Scheduler;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "custom")
MethodParameters:
Name Flags
future
scheduler
public static <T> io.reactivex.Single<T> fromPublisher(org.reactivestreams.Publisher<? extends T>);
descriptor: (Lorg/reactivestreams/Publisher;)Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ldc "publisher is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleFromPublisher
dup
aload 0
invokespecial io.reactivex.internal.operators.single.SingleFromPublisher.<init>:(Lorg/reactivestreams/Publisher;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 publisher Lorg/reactivestreams/Publisher<+TT;>;
Signature: <T:Ljava/lang/Object;>(Lorg/reactivestreams/Publisher<+TT;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.UNBOUNDED_IN:Lio/reactivex/annotations/BackpressureKind;)
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
publisher final
public static <T> io.reactivex.Single<T> fromObservable(io.reactivex.ObservableSource<? extends T>);
descriptor: (Lio/reactivex/ObservableSource;)Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
ldc "observableSource is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.observable.ObservableSingleSingle
dup
aload 0
aconst_null
invokespecial io.reactivex.internal.operators.observable.ObservableSingleSingle.<init>:(Lio/reactivex/ObservableSource;Ljava/lang/Object;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 observableSource Lio/reactivex/ObservableSource<+TT;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/ObservableSource<+TT;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
observableSource
public static <T> io.reactivex.Single<T> just(T);
descriptor: (Ljava/lang/Object;)Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ldc "item is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleJust
dup
aload 0
invokespecial io.reactivex.internal.operators.single.SingleJust.<init>:(Ljava/lang/Object;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 item TT;
Signature: <T:Ljava/lang/Object;>(TT;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
item final
public static <T> io.reactivex.Flowable<T> merge(java.lang.Iterable<? extends io.reactivex.SingleSource<? extends T>>);
descriptor: (Ljava/lang/Iterable;)Lio/reactivex/Flowable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokestatic io.reactivex.Flowable.fromIterable:(Ljava/lang/Iterable;)Lio/reactivex/Flowable;
invokestatic io.reactivex.Single.merge:(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 sources Ljava/lang/Iterable<+Lio/reactivex/SingleSource<+TT;>;>;
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Iterable<+Lio/reactivex/SingleSource<+TT;>;>;)Lio/reactivex/Flowable<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
sources
public static <T> io.reactivex.Flowable<T> merge(org.reactivestreams.Publisher<? extends io.reactivex.SingleSource<? extends T>>);
descriptor: (Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=7, locals=1, args_size=1
start local 0 0: aload 0
ldc "sources is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.flowable.FlowableFlatMapPublisher
dup
aload 0
invokestatic io.reactivex.internal.operators.single.SingleInternalHelper.toFlowable:()Lio/reactivex/functions/Function;
iconst_0
ldc 2147483647
invokestatic io.reactivex.Flowable.bufferSize:()I
invokespecial io.reactivex.internal.operators.flowable.FlowableFlatMapPublisher.<init>:(Lorg/reactivestreams/Publisher;Lio/reactivex/functions/Function;ZII)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Flowable;)Lio/reactivex/Flowable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 sources Lorg/reactivestreams/Publisher<+Lio/reactivex/SingleSource<+TT;>;>;
Signature: <T:Ljava/lang/Object;>(Lorg/reactivestreams/Publisher<+Lio/reactivex/SingleSource<+TT;>;>;)Lio/reactivex/Flowable<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
sources
public static <T> io.reactivex.Single<T> merge(io.reactivex.SingleSource<? extends io.reactivex.SingleSource<? extends T>>);
descriptor: (Lio/reactivex/SingleSource;)Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
ldc "source is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleFlatMap
dup
aload 0
invokestatic io.reactivex.internal.functions.Functions.identity:()Lio/reactivex/functions/Function;
invokespecial io.reactivex.internal.operators.single.SingleFlatMap.<init>:(Lio/reactivex/SingleSource;Lio/reactivex/functions/Function;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 source Lio/reactivex/SingleSource<+Lio/reactivex/SingleSource<+TT;>;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/SingleSource<+Lio/reactivex/SingleSource<+TT;>;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
source
public static <T> io.reactivex.Flowable<T> merge(io.reactivex.SingleSource<? extends T>, io.reactivex.SingleSource<? extends T>);
descriptor: (Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;)Lio/reactivex/Flowable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
ldc "source1 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 1
ldc "source2 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: iconst_2
anewarray io.reactivex.SingleSource
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
invokestatic io.reactivex.Flowable.fromArray:([Ljava/lang/Object;)Lio/reactivex/Flowable;
invokestatic io.reactivex.Single.merge:(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 source1 Lio/reactivex/SingleSource<+TT;>;
0 3 1 source2 Lio/reactivex/SingleSource<+TT;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/SingleSource<+TT;>;Lio/reactivex/SingleSource<+TT;>;)Lio/reactivex/Flowable<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
source1
source2
public static <T> io.reactivex.Flowable<T> merge(io.reactivex.SingleSource<? extends T>, io.reactivex.SingleSource<? extends T>, io.reactivex.SingleSource<? extends T>);
descriptor: (Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;)Lio/reactivex/Flowable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
ldc "source1 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 1
ldc "source2 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 2
ldc "source3 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
3: iconst_3
anewarray io.reactivex.SingleSource
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
dup
iconst_2
aload 2
aastore
invokestatic io.reactivex.Flowable.fromArray:([Ljava/lang/Object;)Lio/reactivex/Flowable;
invokestatic io.reactivex.Single.merge:(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 source1 Lio/reactivex/SingleSource<+TT;>;
0 4 1 source2 Lio/reactivex/SingleSource<+TT;>;
0 4 2 source3 Lio/reactivex/SingleSource<+TT;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/SingleSource<+TT;>;Lio/reactivex/SingleSource<+TT;>;Lio/reactivex/SingleSource<+TT;>;)Lio/reactivex/Flowable<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
source1
source2
source3
public static <T> io.reactivex.Flowable<T> merge(io.reactivex.SingleSource<? extends T>, io.reactivex.SingleSource<? extends T>, io.reactivex.SingleSource<? extends T>, io.reactivex.SingleSource<? extends T>);
descriptor: (Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;)Lio/reactivex/Flowable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
ldc "source1 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 1
ldc "source2 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 2
ldc "source3 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
3: aload 3
ldc "source4 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
4: iconst_4
anewarray io.reactivex.SingleSource
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
dup
iconst_2
aload 2
aastore
dup
iconst_3
aload 3
aastore
invokestatic io.reactivex.Flowable.fromArray:([Ljava/lang/Object;)Lio/reactivex/Flowable;
invokestatic io.reactivex.Single.merge:(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 source1 Lio/reactivex/SingleSource<+TT;>;
0 5 1 source2 Lio/reactivex/SingleSource<+TT;>;
0 5 2 source3 Lio/reactivex/SingleSource<+TT;>;
0 5 3 source4 Lio/reactivex/SingleSource<+TT;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/SingleSource<+TT;>;Lio/reactivex/SingleSource<+TT;>;Lio/reactivex/SingleSource<+TT;>;Lio/reactivex/SingleSource<+TT;>;)Lio/reactivex/Flowable<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
source1
source2
source3
source4
public static <T> io.reactivex.Flowable<T> mergeDelayError(java.lang.Iterable<? extends io.reactivex.SingleSource<? extends T>>);
descriptor: (Ljava/lang/Iterable;)Lio/reactivex/Flowable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokestatic io.reactivex.Flowable.fromIterable:(Ljava/lang/Iterable;)Lio/reactivex/Flowable;
invokestatic io.reactivex.Single.mergeDelayError:(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 sources Ljava/lang/Iterable<+Lio/reactivex/SingleSource<+TT;>;>;
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Iterable<+Lio/reactivex/SingleSource<+TT;>;>;)Lio/reactivex/Flowable<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
sources
public static <T> io.reactivex.Flowable<T> mergeDelayError(org.reactivestreams.Publisher<? extends io.reactivex.SingleSource<? extends T>>);
descriptor: (Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=7, locals=1, args_size=1
start local 0 0: aload 0
ldc "sources is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.flowable.FlowableFlatMapPublisher
dup
aload 0
invokestatic io.reactivex.internal.operators.single.SingleInternalHelper.toFlowable:()Lio/reactivex/functions/Function;
iconst_1
ldc 2147483647
invokestatic io.reactivex.Flowable.bufferSize:()I
invokespecial io.reactivex.internal.operators.flowable.FlowableFlatMapPublisher.<init>:(Lorg/reactivestreams/Publisher;Lio/reactivex/functions/Function;ZII)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Flowable;)Lio/reactivex/Flowable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 sources Lorg/reactivestreams/Publisher<+Lio/reactivex/SingleSource<+TT;>;>;
Signature: <T:Ljava/lang/Object;>(Lorg/reactivestreams/Publisher<+Lio/reactivex/SingleSource<+TT;>;>;)Lio/reactivex/Flowable<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
sources
public static <T> io.reactivex.Flowable<T> mergeDelayError(io.reactivex.SingleSource<? extends T>, io.reactivex.SingleSource<? extends T>);
descriptor: (Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;)Lio/reactivex/Flowable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
ldc "source1 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 1
ldc "source2 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: iconst_2
anewarray io.reactivex.SingleSource
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
invokestatic io.reactivex.Flowable.fromArray:([Ljava/lang/Object;)Lio/reactivex/Flowable;
invokestatic io.reactivex.Single.mergeDelayError:(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 source1 Lio/reactivex/SingleSource<+TT;>;
0 3 1 source2 Lio/reactivex/SingleSource<+TT;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/SingleSource<+TT;>;Lio/reactivex/SingleSource<+TT;>;)Lio/reactivex/Flowable<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
source1
source2
public static <T> io.reactivex.Flowable<T> mergeDelayError(io.reactivex.SingleSource<? extends T>, io.reactivex.SingleSource<? extends T>, io.reactivex.SingleSource<? extends T>);
descriptor: (Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;)Lio/reactivex/Flowable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
ldc "source1 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 1
ldc "source2 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 2
ldc "source3 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
3: iconst_3
anewarray io.reactivex.SingleSource
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
dup
iconst_2
aload 2
aastore
invokestatic io.reactivex.Flowable.fromArray:([Ljava/lang/Object;)Lio/reactivex/Flowable;
invokestatic io.reactivex.Single.mergeDelayError:(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 source1 Lio/reactivex/SingleSource<+TT;>;
0 4 1 source2 Lio/reactivex/SingleSource<+TT;>;
0 4 2 source3 Lio/reactivex/SingleSource<+TT;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/SingleSource<+TT;>;Lio/reactivex/SingleSource<+TT;>;Lio/reactivex/SingleSource<+TT;>;)Lio/reactivex/Flowable<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
source1
source2
source3
public static <T> io.reactivex.Flowable<T> mergeDelayError(io.reactivex.SingleSource<? extends T>, io.reactivex.SingleSource<? extends T>, io.reactivex.SingleSource<? extends T>, io.reactivex.SingleSource<? extends T>);
descriptor: (Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;)Lio/reactivex/Flowable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
ldc "source1 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 1
ldc "source2 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 2
ldc "source3 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
3: aload 3
ldc "source4 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
4: iconst_4
anewarray io.reactivex.SingleSource
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
dup
iconst_2
aload 2
aastore
dup
iconst_3
aload 3
aastore
invokestatic io.reactivex.Flowable.fromArray:([Ljava/lang/Object;)Lio/reactivex/Flowable;
invokestatic io.reactivex.Single.mergeDelayError:(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 source1 Lio/reactivex/SingleSource<+TT;>;
0 5 1 source2 Lio/reactivex/SingleSource<+TT;>;
0 5 2 source3 Lio/reactivex/SingleSource<+TT;>;
0 5 3 source4 Lio/reactivex/SingleSource<+TT;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/SingleSource<+TT;>;Lio/reactivex/SingleSource<+TT;>;Lio/reactivex/SingleSource<+TT;>;Lio/reactivex/SingleSource<+TT;>;)Lio/reactivex/Flowable<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
source1
source2
source3
source4
public static <T> io.reactivex.Single<T> never();
descriptor: ()Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: getstatic io.reactivex.internal.operators.single.SingleNever.INSTANCE:Lio/reactivex/Single;
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
LocalVariableTable:
Start End Slot Name Signature
Signature: <T:Ljava/lang/Object;>()Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
public static io.reactivex.Single<java.lang.Long> timer(long, java.util.concurrent.TimeUnit);
descriptor: (JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=3, args_size=2
start local 0 start local 2 0: lload 0
aload 2
invokestatic io.reactivex.schedulers.Schedulers.computation:()Lio/reactivex/Scheduler;
invokestatic io.reactivex.Single.timer:(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Single;
areturn
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 delay J
0 1 2 unit Ljava/util/concurrent/TimeUnit;
Signature: (JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Single<Ljava/lang/Long;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "io.reactivex:computation")
MethodParameters:
Name Flags
delay
unit
public static io.reactivex.Single<java.lang.Long> timer(long, java.util.concurrent.TimeUnit, io.reactivex.Scheduler);
descriptor: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=4, args_size=3
start local 0 start local 2 start local 3 0: aload 2
ldc "unit is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 3
ldc "scheduler is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: new io.reactivex.internal.operators.single.SingleTimer
dup
lload 0
aload 2
aload 3
invokespecial io.reactivex.internal.operators.single.SingleTimer.<init>:(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 3 end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 delay J
0 3 2 unit Ljava/util/concurrent/TimeUnit;
0 3 3 scheduler Lio/reactivex/Scheduler;
Signature: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Single<Ljava/lang/Long;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "custom")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
delay final
unit final
scheduler final
public static <T> io.reactivex.Single<java.lang.Boolean> equals(io.reactivex.SingleSource<? extends T>, io.reactivex.SingleSource<? extends T>);
descriptor: (Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;)Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
ldc "first is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 1
ldc "second is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: new io.reactivex.internal.operators.single.SingleEquals
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.single.SingleEquals.<init>:(Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 first Lio/reactivex/SingleSource<+TT;>;
0 3 1 second Lio/reactivex/SingleSource<+TT;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/SingleSource<+TT;>;Lio/reactivex/SingleSource<+TT;>;)Lio/reactivex/Single<Ljava/lang/Boolean;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
first final
second final
public static <T> io.reactivex.Single<T> unsafeCreate(io.reactivex.SingleSource<T>);
descriptor: (Lio/reactivex/SingleSource;)Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ldc "onSubscribe is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
instanceof io.reactivex.Single
ifeq 3
2: new java.lang.IllegalArgumentException
dup
ldc "unsafeCreate(Single) should be upgraded"
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
3: StackMap locals:
StackMap stack:
new io.reactivex.internal.operators.single.SingleFromUnsafeSource
dup
aload 0
invokespecial io.reactivex.internal.operators.single.SingleFromUnsafeSource.<init>:(Lio/reactivex/SingleSource;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 onSubscribe Lio/reactivex/SingleSource<TT;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/SingleSource<TT;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
onSubscribe
public static <T, U> io.reactivex.Single<T> using(java.util.concurrent.Callable<U>, io.reactivex.functions.Function<? super U, ? extends io.reactivex.SingleSource<? extends T>>, io.reactivex.functions.Consumer<? super U>);
descriptor: (Ljava/util/concurrent/Callable;Lio/reactivex/functions/Function;Lio/reactivex/functions/Consumer;)Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
iconst_1
invokestatic io.reactivex.Single.using:(Ljava/util/concurrent/Callable;Lio/reactivex/functions/Function;Lio/reactivex/functions/Consumer;Z)Lio/reactivex/Single;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 resourceSupplier Ljava/util/concurrent/Callable<TU;>;
0 1 1 singleFunction Lio/reactivex/functions/Function<-TU;+Lio/reactivex/SingleSource<+TT;>;>;
0 1 2 disposer Lio/reactivex/functions/Consumer<-TU;>;
Signature: <T:Ljava/lang/Object;U:Ljava/lang/Object;>(Ljava/util/concurrent/Callable<TU;>;Lio/reactivex/functions/Function<-TU;+Lio/reactivex/SingleSource<+TT;>;>;Lio/reactivex/functions/Consumer<-TU;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
resourceSupplier
singleFunction
disposer
public static <T, U> io.reactivex.Single<T> using(java.util.concurrent.Callable<U>, io.reactivex.functions.Function<? super U, ? extends io.reactivex.SingleSource<? extends T>>, io.reactivex.functions.Consumer<? super U>, boolean);
descriptor: (Ljava/util/concurrent/Callable;Lio/reactivex/functions/Function;Lio/reactivex/functions/Consumer;Z)Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
ldc "resourceSupplier is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 1
ldc "singleFunction is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 2
ldc "disposer is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
3: new io.reactivex.internal.operators.single.SingleUsing
dup
aload 0
aload 1
aload 2
iload 3
invokespecial io.reactivex.internal.operators.single.SingleUsing.<init>:(Ljava/util/concurrent/Callable;Lio/reactivex/functions/Function;Lio/reactivex/functions/Consumer;Z)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 resourceSupplier Ljava/util/concurrent/Callable<TU;>;
0 4 1 singleFunction Lio/reactivex/functions/Function<-TU;+Lio/reactivex/SingleSource<+TT;>;>;
0 4 2 disposer Lio/reactivex/functions/Consumer<-TU;>;
0 4 3 eager Z
Signature: <T:Ljava/lang/Object;U:Ljava/lang/Object;>(Ljava/util/concurrent/Callable<TU;>;Lio/reactivex/functions/Function<-TU;+Lio/reactivex/SingleSource<+TT;>;>;Lio/reactivex/functions/Consumer<-TU;>;Z)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
resourceSupplier final
singleFunction final
disposer final
eager final
public static <T> io.reactivex.Single<T> wrap(io.reactivex.SingleSource<T>);
descriptor: (Lio/reactivex/SingleSource;)Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ldc "source is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
instanceof io.reactivex.Single
ifeq 3
2: aload 0
checkcast io.reactivex.Single
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
3: StackMap locals:
StackMap stack:
new io.reactivex.internal.operators.single.SingleFromUnsafeSource
dup
aload 0
invokespecial io.reactivex.internal.operators.single.SingleFromUnsafeSource.<init>:(Lio/reactivex/SingleSource;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 source Lio/reactivex/SingleSource<TT;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/SingleSource<TT;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
source
public static <T, R> io.reactivex.Single<R> zip(java.lang.Iterable<? extends io.reactivex.SingleSource<? extends T>>, io.reactivex.functions.Function<? super java.lang.Object[], ? extends R>);
descriptor: (Ljava/lang/Iterable;Lio/reactivex/functions/Function;)Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "zipper is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
ldc "sources is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: new io.reactivex.internal.operators.single.SingleZipIterable
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.single.SingleZipIterable.<init>:(Ljava/lang/Iterable;Lio/reactivex/functions/Function;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 sources Ljava/lang/Iterable<+Lio/reactivex/SingleSource<+TT;>;>;
0 3 1 zipper Lio/reactivex/functions/Function<-[Ljava/lang/Object;+TR;>;
Signature: <T:Ljava/lang/Object;R:Ljava/lang/Object;>(Ljava/lang/Iterable<+Lio/reactivex/SingleSource<+TT;>;>;Lio/reactivex/functions/Function<-[Ljava/lang/Object;+TR;>;)Lio/reactivex/Single<TR;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
sources final
zipper
public static <T1, T2, R> io.reactivex.Single<R> zip(io.reactivex.SingleSource<? extends T1>, io.reactivex.SingleSource<? extends T2>, io.reactivex.functions.BiFunction<? super T1, ? super T2, ? extends R>);
descriptor: (Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/functions/BiFunction;)Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
ldc "source1 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 1
ldc "source2 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 2
invokestatic io.reactivex.internal.functions.Functions.toFunction:(Lio/reactivex/functions/BiFunction;)Lio/reactivex/functions/Function;
iconst_2
anewarray io.reactivex.SingleSource
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
invokestatic io.reactivex.Single.zipArray:(Lio/reactivex/functions/Function;[Lio/reactivex/SingleSource;)Lio/reactivex/Single;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 source1 Lio/reactivex/SingleSource<+TT1;>;
0 3 1 source2 Lio/reactivex/SingleSource<+TT2;>;
0 3 2 zipper Lio/reactivex/functions/BiFunction<-TT1;-TT2;+TR;>;
Signature: <T1:Ljava/lang/Object;T2:Ljava/lang/Object;R:Ljava/lang/Object;>(Lio/reactivex/SingleSource<+TT1;>;Lio/reactivex/SingleSource<+TT2;>;Lio/reactivex/functions/BiFunction<-TT1;-TT2;+TR;>;)Lio/reactivex/Single<TR;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
source1
source2
zipper
public static <T1, T2, T3, R> io.reactivex.Single<R> zip(io.reactivex.SingleSource<? extends T1>, io.reactivex.SingleSource<? extends T2>, io.reactivex.SingleSource<? extends T3>, io.reactivex.functions.Function3<? super T1, ? super T2, ? super T3, ? extends R>);
descriptor: (Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/functions/Function3;)Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
ldc "source1 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 1
ldc "source2 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 2
ldc "source3 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
3: aload 3
invokestatic io.reactivex.internal.functions.Functions.toFunction:(Lio/reactivex/functions/Function3;)Lio/reactivex/functions/Function;
iconst_3
anewarray io.reactivex.SingleSource
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
dup
iconst_2
aload 2
aastore
invokestatic io.reactivex.Single.zipArray:(Lio/reactivex/functions/Function;[Lio/reactivex/SingleSource;)Lio/reactivex/Single;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 source1 Lio/reactivex/SingleSource<+TT1;>;
0 4 1 source2 Lio/reactivex/SingleSource<+TT2;>;
0 4 2 source3 Lio/reactivex/SingleSource<+TT3;>;
0 4 3 zipper Lio/reactivex/functions/Function3<-TT1;-TT2;-TT3;+TR;>;
Signature: <T1:Ljava/lang/Object;T2:Ljava/lang/Object;T3:Ljava/lang/Object;R:Ljava/lang/Object;>(Lio/reactivex/SingleSource<+TT1;>;Lio/reactivex/SingleSource<+TT2;>;Lio/reactivex/SingleSource<+TT3;>;Lio/reactivex/functions/Function3<-TT1;-TT2;-TT3;+TR;>;)Lio/reactivex/Single<TR;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
source1
source2
source3
zipper
public static <T1, T2, T3, T4, R> io.reactivex.Single<R> zip(io.reactivex.SingleSource<? extends T1>, io.reactivex.SingleSource<? extends T2>, io.reactivex.SingleSource<? extends T3>, io.reactivex.SingleSource<? extends T4>, io.reactivex.functions.Function4<? super T1, ? super T2, ? super T3, ? super T4, ? extends R>);
descriptor: (Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/functions/Function4;)Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
ldc "source1 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 1
ldc "source2 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 2
ldc "source3 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
3: aload 3
ldc "source4 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
4: aload 4
invokestatic io.reactivex.internal.functions.Functions.toFunction:(Lio/reactivex/functions/Function4;)Lio/reactivex/functions/Function;
iconst_4
anewarray io.reactivex.SingleSource
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
dup
iconst_2
aload 2
aastore
dup
iconst_3
aload 3
aastore
invokestatic io.reactivex.Single.zipArray:(Lio/reactivex/functions/Function;[Lio/reactivex/SingleSource;)Lio/reactivex/Single;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 source1 Lio/reactivex/SingleSource<+TT1;>;
0 5 1 source2 Lio/reactivex/SingleSource<+TT2;>;
0 5 2 source3 Lio/reactivex/SingleSource<+TT3;>;
0 5 3 source4 Lio/reactivex/SingleSource<+TT4;>;
0 5 4 zipper Lio/reactivex/functions/Function4<-TT1;-TT2;-TT3;-TT4;+TR;>;
Signature: <T1:Ljava/lang/Object;T2:Ljava/lang/Object;T3:Ljava/lang/Object;T4:Ljava/lang/Object;R:Ljava/lang/Object;>(Lio/reactivex/SingleSource<+TT1;>;Lio/reactivex/SingleSource<+TT2;>;Lio/reactivex/SingleSource<+TT3;>;Lio/reactivex/SingleSource<+TT4;>;Lio/reactivex/functions/Function4<-TT1;-TT2;-TT3;-TT4;+TR;>;)Lio/reactivex/Single<TR;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
source1
source2
source3
source4
zipper
public static <T1, T2, T3, T4, T5, R> io.reactivex.Single<R> zip(io.reactivex.SingleSource<? extends T1>, io.reactivex.SingleSource<? extends T2>, io.reactivex.SingleSource<? extends T3>, io.reactivex.SingleSource<? extends T4>, io.reactivex.SingleSource<? extends T5>, io.reactivex.functions.Function5<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R>);
descriptor: (Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/functions/Function5;)Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, 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
ldc "source1 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 1
ldc "source2 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 2
ldc "source3 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
3: aload 3
ldc "source4 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
4: aload 4
ldc "source5 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
5: aload 5
invokestatic io.reactivex.internal.functions.Functions.toFunction:(Lio/reactivex/functions/Function5;)Lio/reactivex/functions/Function;
iconst_5
anewarray io.reactivex.SingleSource
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
dup
iconst_2
aload 2
aastore
dup
iconst_3
aload 3
aastore
dup
iconst_4
aload 4
aastore
invokestatic io.reactivex.Single.zipArray:(Lio/reactivex/functions/Function;[Lio/reactivex/SingleSource;)Lio/reactivex/Single;
areturn
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 6 0 source1 Lio/reactivex/SingleSource<+TT1;>;
0 6 1 source2 Lio/reactivex/SingleSource<+TT2;>;
0 6 2 source3 Lio/reactivex/SingleSource<+TT3;>;
0 6 3 source4 Lio/reactivex/SingleSource<+TT4;>;
0 6 4 source5 Lio/reactivex/SingleSource<+TT5;>;
0 6 5 zipper Lio/reactivex/functions/Function5<-TT1;-TT2;-TT3;-TT4;-TT5;+TR;>;
Signature: <T1:Ljava/lang/Object;T2:Ljava/lang/Object;T3:Ljava/lang/Object;T4:Ljava/lang/Object;T5:Ljava/lang/Object;R:Ljava/lang/Object;>(Lio/reactivex/SingleSource<+TT1;>;Lio/reactivex/SingleSource<+TT2;>;Lio/reactivex/SingleSource<+TT3;>;Lio/reactivex/SingleSource<+TT4;>;Lio/reactivex/SingleSource<+TT5;>;Lio/reactivex/functions/Function5<-TT1;-TT2;-TT3;-TT4;-TT5;+TR;>;)Lio/reactivex/Single<TR;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
source1
source2
source3
source4
source5
zipper
public static <T1, T2, T3, T4, T5, T6, R> io.reactivex.Single<R> zip(io.reactivex.SingleSource<? extends T1>, io.reactivex.SingleSource<? extends T2>, io.reactivex.SingleSource<? extends T3>, io.reactivex.SingleSource<? extends T4>, io.reactivex.SingleSource<? extends T5>, io.reactivex.SingleSource<? extends T6>, io.reactivex.functions.Function6<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R>);
descriptor: (Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/functions/Function6;)Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=7, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 0: aload 0
ldc "source1 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 1
ldc "source2 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 2
ldc "source3 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
3: aload 3
ldc "source4 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
4: aload 4
ldc "source5 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
5: aload 5
ldc "source6 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
6: aload 6
invokestatic io.reactivex.internal.functions.Functions.toFunction:(Lio/reactivex/functions/Function6;)Lio/reactivex/functions/Function;
bipush 6
anewarray io.reactivex.SingleSource
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
dup
iconst_2
aload 2
aastore
dup
iconst_3
aload 3
aastore
dup
iconst_4
aload 4
aastore
dup
iconst_5
aload 5
aastore
invokestatic io.reactivex.Single.zipArray:(Lio/reactivex/functions/Function;[Lio/reactivex/SingleSource;)Lio/reactivex/Single;
areturn
end local 6 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 7 0 source1 Lio/reactivex/SingleSource<+TT1;>;
0 7 1 source2 Lio/reactivex/SingleSource<+TT2;>;
0 7 2 source3 Lio/reactivex/SingleSource<+TT3;>;
0 7 3 source4 Lio/reactivex/SingleSource<+TT4;>;
0 7 4 source5 Lio/reactivex/SingleSource<+TT5;>;
0 7 5 source6 Lio/reactivex/SingleSource<+TT6;>;
0 7 6 zipper Lio/reactivex/functions/Function6<-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;+TR;>;
Signature: <T1:Ljava/lang/Object;T2:Ljava/lang/Object;T3:Ljava/lang/Object;T4:Ljava/lang/Object;T5:Ljava/lang/Object;T6:Ljava/lang/Object;R:Ljava/lang/Object;>(Lio/reactivex/SingleSource<+TT1;>;Lio/reactivex/SingleSource<+TT2;>;Lio/reactivex/SingleSource<+TT3;>;Lio/reactivex/SingleSource<+TT4;>;Lio/reactivex/SingleSource<+TT5;>;Lio/reactivex/SingleSource<+TT6;>;Lio/reactivex/functions/Function6<-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;+TR;>;)Lio/reactivex/Single<TR;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
source1
source2
source3
source4
source5
source6
zipper
public static <T1, T2, T3, T4, T5, T6, T7, R> io.reactivex.Single<R> zip(io.reactivex.SingleSource<? extends T1>, io.reactivex.SingleSource<? extends T2>, io.reactivex.SingleSource<? extends T3>, io.reactivex.SingleSource<? extends T4>, io.reactivex.SingleSource<? extends T5>, io.reactivex.SingleSource<? extends T6>, io.reactivex.SingleSource<? extends T7>, io.reactivex.functions.Function7<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R>);
descriptor: (Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/functions/Function7;)Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=8, args_size=8
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 start local 7 0: aload 0
ldc "source1 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 1
ldc "source2 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 2
ldc "source3 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
3: aload 3
ldc "source4 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
4: aload 4
ldc "source5 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
5: aload 5
ldc "source6 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
6: aload 6
ldc "source7 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
7: aload 7
invokestatic io.reactivex.internal.functions.Functions.toFunction:(Lio/reactivex/functions/Function7;)Lio/reactivex/functions/Function;
bipush 7
anewarray io.reactivex.SingleSource
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
dup
iconst_2
aload 2
aastore
dup
iconst_3
aload 3
aastore
dup
iconst_4
aload 4
aastore
dup
iconst_5
aload 5
aastore
dup
bipush 6
aload 6
aastore
invokestatic io.reactivex.Single.zipArray:(Lio/reactivex/functions/Function;[Lio/reactivex/SingleSource;)Lio/reactivex/Single;
areturn
end local 7 end local 6 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 source1 Lio/reactivex/SingleSource<+TT1;>;
0 8 1 source2 Lio/reactivex/SingleSource<+TT2;>;
0 8 2 source3 Lio/reactivex/SingleSource<+TT3;>;
0 8 3 source4 Lio/reactivex/SingleSource<+TT4;>;
0 8 4 source5 Lio/reactivex/SingleSource<+TT5;>;
0 8 5 source6 Lio/reactivex/SingleSource<+TT6;>;
0 8 6 source7 Lio/reactivex/SingleSource<+TT7;>;
0 8 7 zipper Lio/reactivex/functions/Function7<-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;-TT7;+TR;>;
Signature: <T1:Ljava/lang/Object;T2:Ljava/lang/Object;T3:Ljava/lang/Object;T4:Ljava/lang/Object;T5:Ljava/lang/Object;T6:Ljava/lang/Object;T7:Ljava/lang/Object;R:Ljava/lang/Object;>(Lio/reactivex/SingleSource<+TT1;>;Lio/reactivex/SingleSource<+TT2;>;Lio/reactivex/SingleSource<+TT3;>;Lio/reactivex/SingleSource<+TT4;>;Lio/reactivex/SingleSource<+TT5;>;Lio/reactivex/SingleSource<+TT6;>;Lio/reactivex/SingleSource<+TT7;>;Lio/reactivex/functions/Function7<-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;-TT7;+TR;>;)Lio/reactivex/Single<TR;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
source1
source2
source3
source4
source5
source6
source7
zipper
public static <T1, T2, T3, T4, T5, T6, T7, T8, R> io.reactivex.Single<R> zip(io.reactivex.SingleSource<? extends T1>, io.reactivex.SingleSource<? extends T2>, io.reactivex.SingleSource<? extends T3>, io.reactivex.SingleSource<? extends T4>, io.reactivex.SingleSource<? extends T5>, io.reactivex.SingleSource<? extends T6>, io.reactivex.SingleSource<? extends T7>, io.reactivex.SingleSource<? extends T8>, io.reactivex.functions.Function8<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R>);
descriptor: (Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/functions/Function8;)Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=9, args_size=9
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 start local 7 start local 8 0: aload 0
ldc "source1 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 1
ldc "source2 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 2
ldc "source3 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
3: aload 3
ldc "source4 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
4: aload 4
ldc "source5 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
5: aload 5
ldc "source6 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
6: aload 6
ldc "source7 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
7: aload 7
ldc "source8 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
8: aload 8
invokestatic io.reactivex.internal.functions.Functions.toFunction:(Lio/reactivex/functions/Function8;)Lio/reactivex/functions/Function;
bipush 8
anewarray io.reactivex.SingleSource
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
dup
iconst_2
aload 2
aastore
dup
iconst_3
aload 3
aastore
dup
iconst_4
aload 4
aastore
dup
iconst_5
aload 5
aastore
dup
bipush 6
aload 6
aastore
dup
bipush 7
aload 7
aastore
invokestatic io.reactivex.Single.zipArray:(Lio/reactivex/functions/Function;[Lio/reactivex/SingleSource;)Lio/reactivex/Single;
areturn
end local 8 end local 7 end local 6 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 9 0 source1 Lio/reactivex/SingleSource<+TT1;>;
0 9 1 source2 Lio/reactivex/SingleSource<+TT2;>;
0 9 2 source3 Lio/reactivex/SingleSource<+TT3;>;
0 9 3 source4 Lio/reactivex/SingleSource<+TT4;>;
0 9 4 source5 Lio/reactivex/SingleSource<+TT5;>;
0 9 5 source6 Lio/reactivex/SingleSource<+TT6;>;
0 9 6 source7 Lio/reactivex/SingleSource<+TT7;>;
0 9 7 source8 Lio/reactivex/SingleSource<+TT8;>;
0 9 8 zipper Lio/reactivex/functions/Function8<-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;-TT7;-TT8;+TR;>;
Signature: <T1:Ljava/lang/Object;T2:Ljava/lang/Object;T3:Ljava/lang/Object;T4:Ljava/lang/Object;T5:Ljava/lang/Object;T6:Ljava/lang/Object;T7:Ljava/lang/Object;T8:Ljava/lang/Object;R:Ljava/lang/Object;>(Lio/reactivex/SingleSource<+TT1;>;Lio/reactivex/SingleSource<+TT2;>;Lio/reactivex/SingleSource<+TT3;>;Lio/reactivex/SingleSource<+TT4;>;Lio/reactivex/SingleSource<+TT5;>;Lio/reactivex/SingleSource<+TT6;>;Lio/reactivex/SingleSource<+TT7;>;Lio/reactivex/SingleSource<+TT8;>;Lio/reactivex/functions/Function8<-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;-TT7;-TT8;+TR;>;)Lio/reactivex/Single<TR;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
source1
source2
source3
source4
source5
source6
source7
source8
zipper
public static <T1, T2, T3, T4, T5, T6, T7, T8, T9, R> io.reactivex.Single<R> zip(io.reactivex.SingleSource<? extends T1>, io.reactivex.SingleSource<? extends T2>, io.reactivex.SingleSource<? extends T3>, io.reactivex.SingleSource<? extends T4>, io.reactivex.SingleSource<? extends T5>, io.reactivex.SingleSource<? extends T6>, io.reactivex.SingleSource<? extends T7>, io.reactivex.SingleSource<? extends T8>, io.reactivex.SingleSource<? extends T9>, io.reactivex.functions.Function9<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R>);
descriptor: (Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/functions/Function9;)Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=10, args_size=10
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 start local 7 start local 8 start local 9 0: aload 0
ldc "source1 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 1
ldc "source2 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 2
ldc "source3 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
3: aload 3
ldc "source4 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
4: aload 4
ldc "source5 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
5: aload 5
ldc "source6 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
6: aload 6
ldc "source7 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
7: aload 7
ldc "source8 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
8: aload 8
ldc "source9 is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
9: aload 9
invokestatic io.reactivex.internal.functions.Functions.toFunction:(Lio/reactivex/functions/Function9;)Lio/reactivex/functions/Function;
bipush 9
anewarray io.reactivex.SingleSource
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
dup
iconst_2
aload 2
aastore
dup
iconst_3
aload 3
aastore
dup
iconst_4
aload 4
aastore
dup
iconst_5
aload 5
aastore
dup
bipush 6
aload 6
aastore
dup
bipush 7
aload 7
aastore
dup
bipush 8
aload 8
aastore
invokestatic io.reactivex.Single.zipArray:(Lio/reactivex/functions/Function;[Lio/reactivex/SingleSource;)Lio/reactivex/Single;
areturn
end local 9 end local 8 end local 7 end local 6 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 10 0 source1 Lio/reactivex/SingleSource<+TT1;>;
0 10 1 source2 Lio/reactivex/SingleSource<+TT2;>;
0 10 2 source3 Lio/reactivex/SingleSource<+TT3;>;
0 10 3 source4 Lio/reactivex/SingleSource<+TT4;>;
0 10 4 source5 Lio/reactivex/SingleSource<+TT5;>;
0 10 5 source6 Lio/reactivex/SingleSource<+TT6;>;
0 10 6 source7 Lio/reactivex/SingleSource<+TT7;>;
0 10 7 source8 Lio/reactivex/SingleSource<+TT8;>;
0 10 8 source9 Lio/reactivex/SingleSource<+TT9;>;
0 10 9 zipper Lio/reactivex/functions/Function9<-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;-TT7;-TT8;-TT9;+TR;>;
Signature: <T1:Ljava/lang/Object;T2:Ljava/lang/Object;T3:Ljava/lang/Object;T4:Ljava/lang/Object;T5:Ljava/lang/Object;T6:Ljava/lang/Object;T7:Ljava/lang/Object;T8:Ljava/lang/Object;T9:Ljava/lang/Object;R:Ljava/lang/Object;>(Lio/reactivex/SingleSource<+TT1;>;Lio/reactivex/SingleSource<+TT2;>;Lio/reactivex/SingleSource<+TT3;>;Lio/reactivex/SingleSource<+TT4;>;Lio/reactivex/SingleSource<+TT5;>;Lio/reactivex/SingleSource<+TT6;>;Lio/reactivex/SingleSource<+TT7;>;Lio/reactivex/SingleSource<+TT8;>;Lio/reactivex/SingleSource<+TT9;>;Lio/reactivex/functions/Function9<-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;-TT7;-TT8;-TT9;+TR;>;)Lio/reactivex/Single<TR;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
source1
source2
source3
source4
source5
source6
source7
source8
source9
zipper
public static <T, R> io.reactivex.Single<R> zipArray(io.reactivex.functions.Function<? super java.lang.Object[], ? extends R>, io.reactivex.SingleSource<? extends T>[]);
descriptor: (Lio/reactivex/functions/Function;[Lio/reactivex/SingleSource;)Lio/reactivex/Single;
flags: (0x0089) ACC_PUBLIC, ACC_STATIC, ACC_VARARGS
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
ldc "zipper is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 1
ldc "sources is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 1
arraylength
ifne 4
3: new java.util.NoSuchElementException
dup
invokespecial java.util.NoSuchElementException.<init>:()V
invokestatic io.reactivex.Single.error:(Ljava/lang/Throwable;)Lio/reactivex/Single;
areturn
4: StackMap locals:
StackMap stack:
new io.reactivex.internal.operators.single.SingleZipArray
dup
aload 1
aload 0
invokespecial io.reactivex.internal.operators.single.SingleZipArray.<init>:([Lio/reactivex/SingleSource;Lio/reactivex/functions/Function;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 zipper Lio/reactivex/functions/Function<-[Ljava/lang/Object;+TR;>;
0 5 1 sources [Lio/reactivex/SingleSource;
Signature: <T:Ljava/lang/Object;R:Ljava/lang/Object;>(Lio/reactivex/functions/Function<-[Ljava/lang/Object;+TR;>;[Lio/reactivex/SingleSource<+TT;>;)Lio/reactivex/Single<TR;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
zipper
sources
public final io.reactivex.Single<T> ambWith(io.reactivex.SingleSource<? extends T>);
descriptor: (Lio/reactivex/SingleSource;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "other is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: iconst_2
anewarray io.reactivex.SingleSource
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
invokestatic io.reactivex.Single.ambArray:([Lio/reactivex/SingleSource;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 other Lio/reactivex/SingleSource<+TT;>;
Signature: (Lio/reactivex/SingleSource<+TT;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
other
public final <R> R as(io.reactivex.SingleConverter<T, ? extends R>);
descriptor: (Lio/reactivex/SingleConverter;)Ljava/lang/Object;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "converter is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast io.reactivex.SingleConverter
aload 0
invokeinterface io.reactivex.SingleConverter.apply:(Lio/reactivex/Single;)Ljava/lang/Object;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
0 1 1 converter Lio/reactivex/SingleConverter<TT;+TR;>;
Signature: <R:Ljava/lang/Object;>(Lio/reactivex/SingleConverter<TT;+TR;>;)TR;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleParameterAnnotations:
0:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
converter
public final io.reactivex.Single<T> hide();
descriptor: ()Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=3, locals=1, args_size=1
start local 0 0: new io.reactivex.internal.operators.single.SingleHide
dup
aload 0
invokespecial io.reactivex.internal.operators.single.SingleHide.<init>:(Lio/reactivex/SingleSource;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
Signature: ()Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
public final <R> io.reactivex.Single<R> compose(io.reactivex.SingleTransformer<? super T, ? extends R>);
descriptor: (Lio/reactivex/SingleTransformer;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "transformer is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast io.reactivex.SingleTransformer
aload 0
invokeinterface io.reactivex.SingleTransformer.apply:(Lio/reactivex/Single;)Lio/reactivex/SingleSource;
invokestatic io.reactivex.Single.wrap:(Lio/reactivex/SingleSource;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
0 1 1 transformer Lio/reactivex/SingleTransformer<-TT;+TR;>;
Signature: <R:Ljava/lang/Object;>(Lio/reactivex/SingleTransformer<-TT;+TR;>;)Lio/reactivex/Single<TR;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
transformer
public final io.reactivex.Single<T> cache();
descriptor: ()Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=3, locals=1, args_size=1
start local 0 0: new io.reactivex.internal.operators.single.SingleCache
dup
aload 0
invokespecial io.reactivex.internal.operators.single.SingleCache.<init>:(Lio/reactivex/SingleSource;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
Signature: ()Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
public final <U> io.reactivex.Single<U> cast(java.lang.Class<? extends U>);
descriptor: (Ljava/lang/Class;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "clazz is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
aload 1
invokestatic io.reactivex.internal.functions.Functions.castFunction:(Ljava/lang/Class;)Lio/reactivex/functions/Function;
invokevirtual io.reactivex.Single.map:(Lio/reactivex/functions/Function;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 clazz Ljava/lang/Class<+TU;>;
Signature: <U:Ljava/lang/Object;>(Ljava/lang/Class<+TU;>;)Lio/reactivex/Single<TU;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
clazz final
public final io.reactivex.Flowable<T> concatWith(io.reactivex.SingleSource<? extends T>);
descriptor: (Lio/reactivex/SingleSource;)Lio/reactivex/Flowable;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic io.reactivex.Single.concat:(Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;)Lio/reactivex/Flowable;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
0 1 1 other Lio/reactivex/SingleSource<+TT;>;
Signature: (Lio/reactivex/SingleSource<+TT;>;)Lio/reactivex/Flowable<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
other
public final io.reactivex.Single<T> delay(long, java.util.concurrent.TimeUnit);
descriptor: (JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=6, locals=4, args_size=3
start local 0 start local 1 start local 3 0: aload 0
lload 1
aload 3
invokestatic io.reactivex.schedulers.Schedulers.computation:()Lio/reactivex/Scheduler;
iconst_0
invokevirtual io.reactivex.Single.delay:(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Z)Lio/reactivex/Single;
areturn
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
0 1 1 time J
0 1 3 unit Ljava/util/concurrent/TimeUnit;
Signature: (JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "io.reactivex:computation")
MethodParameters:
Name Flags
time
unit
public final io.reactivex.Single<T> delay(long, java.util.concurrent.TimeUnit, boolean);
descriptor: (JLjava/util/concurrent/TimeUnit;Z)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=6, locals=5, args_size=4
start local 0 start local 1 start local 3 start local 4 0: aload 0
lload 1
aload 3
invokestatic io.reactivex.schedulers.Schedulers.computation:()Lio/reactivex/Scheduler;
iload 4
invokevirtual io.reactivex.Single.delay:(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Z)Lio/reactivex/Single;
areturn
end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
0 1 1 time J
0 1 3 unit Ljava/util/concurrent/TimeUnit;
0 1 4 delayError Z
Signature: (JLjava/util/concurrent/TimeUnit;Z)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "io.reactivex:computation")
MethodParameters:
Name Flags
time
unit
delayError
public final io.reactivex.Single<T> delay(long, java.util.concurrent.TimeUnit, io.reactivex.Scheduler);
descriptor: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=6, locals=5, args_size=4
start local 0 start local 1 start local 3 start local 4 0: aload 0
lload 1
aload 3
aload 4
iconst_0
invokevirtual io.reactivex.Single.delay:(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Z)Lio/reactivex/Single;
areturn
end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
0 1 1 time J
0 1 3 unit Ljava/util/concurrent/TimeUnit;
0 1 4 scheduler Lio/reactivex/Scheduler;
Signature: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "custom")
MethodParameters:
Name Flags
time final
unit final
scheduler final
public final io.reactivex.Single<T> delay(long, java.util.concurrent.TimeUnit, io.reactivex.Scheduler, boolean);
descriptor: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Z)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=8, locals=6, args_size=5
start local 0 start local 1 start local 3 start local 4 start local 5 0: aload 3
ldc "unit is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 4
ldc "scheduler is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: new io.reactivex.internal.operators.single.SingleDelay
dup
aload 0
lload 1
aload 3
aload 4
iload 5
invokespecial io.reactivex.internal.operators.single.SingleDelay.<init>:(Lio/reactivex/SingleSource;JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Z)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 5 end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactivex/Single<TT;>;
0 3 1 time J
0 3 3 unit Ljava/util/concurrent/TimeUnit;
0 3 4 scheduler Lio/reactivex/Scheduler;
0 3 5 delayError Z
Signature: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Z)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "custom")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
time final
unit final
scheduler final
delayError
public final io.reactivex.Single<T> delaySubscription(io.reactivex.CompletableSource);
descriptor: (Lio/reactivex/CompletableSource;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "other is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleDelayWithCompletable
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.single.SingleDelayWithCompletable.<init>:(Lio/reactivex/SingleSource;Lio/reactivex/CompletableSource;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 other Lio/reactivex/CompletableSource;
Signature: (Lio/reactivex/CompletableSource;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
other
public final <U> io.reactivex.Single<T> delaySubscription(io.reactivex.SingleSource<U>);
descriptor: (Lio/reactivex/SingleSource;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "other is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleDelayWithSingle
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.single.SingleDelayWithSingle.<init>:(Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 other Lio/reactivex/SingleSource<TU;>;
Signature: <U:Ljava/lang/Object;>(Lio/reactivex/SingleSource<TU;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
other
public final <U> io.reactivex.Single<T> delaySubscription(io.reactivex.ObservableSource<U>);
descriptor: (Lio/reactivex/ObservableSource;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "other is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleDelayWithObservable
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.single.SingleDelayWithObservable.<init>:(Lio/reactivex/SingleSource;Lio/reactivex/ObservableSource;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 other Lio/reactivex/ObservableSource<TU;>;
Signature: <U:Ljava/lang/Object;>(Lio/reactivex/ObservableSource<TU;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
other
public final <U> io.reactivex.Single<T> delaySubscription(org.reactivestreams.Publisher<U>);
descriptor: (Lorg/reactivestreams/Publisher;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "other is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleDelayWithPublisher
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.single.SingleDelayWithPublisher.<init>:(Lio/reactivex/SingleSource;Lorg/reactivestreams/Publisher;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 other Lorg/reactivestreams/Publisher<TU;>;
Signature: <U:Ljava/lang/Object;>(Lorg/reactivestreams/Publisher<TU;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
other
public final io.reactivex.Single<T> delaySubscription(long, java.util.concurrent.TimeUnit);
descriptor: (JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=5, locals=4, args_size=3
start local 0 start local 1 start local 3 0: aload 0
lload 1
aload 3
invokestatic io.reactivex.schedulers.Schedulers.computation:()Lio/reactivex/Scheduler;
invokevirtual io.reactivex.Single.delaySubscription:(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Single;
areturn
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
0 1 1 time J
0 1 3 unit Ljava/util/concurrent/TimeUnit;
Signature: (JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "io.reactivex:computation")
MethodParameters:
Name Flags
time
unit
public final io.reactivex.Single<T> delaySubscription(long, java.util.concurrent.TimeUnit, io.reactivex.Scheduler);
descriptor: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=5, locals=5, args_size=4
start local 0 start local 1 start local 3 start local 4 0: aload 0
lload 1
aload 3
aload 4
invokestatic io.reactivex.Observable.timer:(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Observable;
invokevirtual io.reactivex.Single.delaySubscription:(Lio/reactivex/ObservableSource;)Lio/reactivex/Single;
areturn
end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
0 1 1 time J
0 1 3 unit Ljava/util/concurrent/TimeUnit;
0 1 4 scheduler Lio/reactivex/Scheduler;
Signature: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "custom")
MethodParameters:
Name Flags
time
unit
scheduler
public final <R> io.reactivex.Maybe<R> dematerialize(io.reactivex.functions.Function<? super T, io.reactivex.Notification<R>>);
descriptor: (Lio/reactivex/functions/Function;)Lio/reactivex/Maybe;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "selector is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleDematerialize
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.single.SingleDematerialize.<init>:(Lio/reactivex/Single;Lio/reactivex/functions/Function;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 selector Lio/reactivex/functions/Function<-TT;Lio/reactivex/Notification<TR;>;>;
Signature: <R:Ljava/lang/Object;>(Lio/reactivex/functions/Function<-TT;Lio/reactivex/Notification<TR;>;>;)Lio/reactivex/Maybe<TR;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
io.reactivex.annotations.Experimental()
RuntimeInvisibleTypeAnnotations:
METHOD_RETURN
io.reactivex.annotations.Experimental()
MethodParameters:
Name Flags
selector
public final io.reactivex.Single<T> doAfterSuccess(io.reactivex.functions.Consumer<? super T>);
descriptor: (Lio/reactivex/functions/Consumer;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "onAfterSuccess is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleDoAfterSuccess
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.single.SingleDoAfterSuccess.<init>:(Lio/reactivex/SingleSource;Lio/reactivex/functions/Consumer;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 onAfterSuccess Lio/reactivex/functions/Consumer<-TT;>;
Signature: (Lio/reactivex/functions/Consumer<-TT;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
onAfterSuccess
public final io.reactivex.Single<T> doAfterTerminate(io.reactivex.functions.Action);
descriptor: (Lio/reactivex/functions/Action;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "onAfterTerminate is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleDoAfterTerminate
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.single.SingleDoAfterTerminate.<init>:(Lio/reactivex/SingleSource;Lio/reactivex/functions/Action;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 onAfterTerminate Lio/reactivex/functions/Action;
Signature: (Lio/reactivex/functions/Action;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
onAfterTerminate
public final io.reactivex.Single<T> doFinally(io.reactivex.functions.Action);
descriptor: (Lio/reactivex/functions/Action;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "onFinally is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleDoFinally
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.single.SingleDoFinally.<init>:(Lio/reactivex/SingleSource;Lio/reactivex/functions/Action;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 onFinally Lio/reactivex/functions/Action;
Signature: (Lio/reactivex/functions/Action;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
onFinally
public final io.reactivex.Single<T> doOnSubscribe(io.reactivex.functions.Consumer<? super io.reactivex.disposables.Disposable>);
descriptor: (Lio/reactivex/functions/Consumer;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "onSubscribe is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleDoOnSubscribe
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.single.SingleDoOnSubscribe.<init>:(Lio/reactivex/SingleSource;Lio/reactivex/functions/Consumer;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 onSubscribe Lio/reactivex/functions/Consumer<-Lio/reactivex/disposables/Disposable;>;
Signature: (Lio/reactivex/functions/Consumer<-Lio/reactivex/disposables/Disposable;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
onSubscribe final
public final io.reactivex.Single<T> doOnTerminate(io.reactivex.functions.Action);
descriptor: (Lio/reactivex/functions/Action;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "onTerminate is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleDoOnTerminate
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.single.SingleDoOnTerminate.<init>:(Lio/reactivex/SingleSource;Lio/reactivex/functions/Action;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 onTerminate Lio/reactivex/functions/Action;
Signature: (Lio/reactivex/functions/Action;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.Experimental()
io.reactivex.annotations.NonNull()
RuntimeInvisibleTypeAnnotations:
METHOD_RETURN
io.reactivex.annotations.Experimental()
MethodParameters:
Name Flags
onTerminate final
public final io.reactivex.Single<T> doOnSuccess(io.reactivex.functions.Consumer<? super T>);
descriptor: (Lio/reactivex/functions/Consumer;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "onSuccess is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleDoOnSuccess
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.single.SingleDoOnSuccess.<init>:(Lio/reactivex/SingleSource;Lio/reactivex/functions/Consumer;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 onSuccess Lio/reactivex/functions/Consumer<-TT;>;
Signature: (Lio/reactivex/functions/Consumer<-TT;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
onSuccess final
public final io.reactivex.Single<T> doOnEvent(io.reactivex.functions.BiConsumer<? super T, ? super java.lang.Throwable>);
descriptor: (Lio/reactivex/functions/BiConsumer;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "onEvent is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleDoOnEvent
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.single.SingleDoOnEvent.<init>:(Lio/reactivex/SingleSource;Lio/reactivex/functions/BiConsumer;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 onEvent Lio/reactivex/functions/BiConsumer<-TT;-Ljava/lang/Throwable;>;
Signature: (Lio/reactivex/functions/BiConsumer<-TT;-Ljava/lang/Throwable;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
onEvent final
public final io.reactivex.Single<T> doOnError(io.reactivex.functions.Consumer<? super java.lang.Throwable>);
descriptor: (Lio/reactivex/functions/Consumer;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "onError is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleDoOnError
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.single.SingleDoOnError.<init>:(Lio/reactivex/SingleSource;Lio/reactivex/functions/Consumer;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 onError Lio/reactivex/functions/Consumer<-Ljava/lang/Throwable;>;
Signature: (Lio/reactivex/functions/Consumer<-Ljava/lang/Throwable;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
onError final
public final io.reactivex.Single<T> doOnDispose(io.reactivex.functions.Action);
descriptor: (Lio/reactivex/functions/Action;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "onDispose is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleDoOnDispose
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.single.SingleDoOnDispose.<init>:(Lio/reactivex/SingleSource;Lio/reactivex/functions/Action;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 onDispose Lio/reactivex/functions/Action;
Signature: (Lio/reactivex/functions/Action;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
onDispose final
public final io.reactivex.Maybe<T> filter(io.reactivex.functions.Predicate<? super T>);
descriptor: (Lio/reactivex/functions/Predicate;)Lio/reactivex/Maybe;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "predicate is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.maybe.MaybeFilterSingle
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.maybe.MaybeFilterSingle.<init>:(Lio/reactivex/SingleSource;Lio/reactivex/functions/Predicate;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 predicate Lio/reactivex/functions/Predicate<-TT;>;
Signature: (Lio/reactivex/functions/Predicate<-TT;>;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
predicate
public final <R> io.reactivex.Single<R> flatMap(io.reactivex.functions.Function<? super T, ? extends io.reactivex.SingleSource<? extends R>>);
descriptor: (Lio/reactivex/functions/Function;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "mapper is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleFlatMap
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.single.SingleFlatMap.<init>:(Lio/reactivex/SingleSource;Lio/reactivex/functions/Function;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 mapper Lio/reactivex/functions/Function<-TT;+Lio/reactivex/SingleSource<+TR;>;>;
Signature: <R:Ljava/lang/Object;>(Lio/reactivex/functions/Function<-TT;+Lio/reactivex/SingleSource<+TR;>;>;)Lio/reactivex/Single<TR;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
mapper
public final <R> io.reactivex.Maybe<R> flatMapMaybe(io.reactivex.functions.Function<? super T, ? extends io.reactivex.MaybeSource<? extends R>>);
descriptor: (Lio/reactivex/functions/Function;)Lio/reactivex/Maybe;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "mapper is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleFlatMapMaybe
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.single.SingleFlatMapMaybe.<init>:(Lio/reactivex/SingleSource;Lio/reactivex/functions/Function;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 mapper Lio/reactivex/functions/Function<-TT;+Lio/reactivex/MaybeSource<+TR;>;>;
Signature: <R:Ljava/lang/Object;>(Lio/reactivex/functions/Function<-TT;+Lio/reactivex/MaybeSource<+TR;>;>;)Lio/reactivex/Maybe<TR;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
mapper final
public final <R> io.reactivex.Flowable<R> flatMapPublisher(io.reactivex.functions.Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>>);
descriptor: (Lio/reactivex/functions/Function;)Lio/reactivex/Flowable;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "mapper is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleFlatMapPublisher
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.single.SingleFlatMapPublisher.<init>:(Lio/reactivex/SingleSource;Lio/reactivex/functions/Function;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Flowable;)Lio/reactivex/Flowable;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 mapper Lio/reactivex/functions/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;
Signature: <R:Ljava/lang/Object;>(Lio/reactivex/functions/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;)Lio/reactivex/Flowable<TR;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
mapper
public final <U> io.reactivex.Flowable<U> flattenAsFlowable(io.reactivex.functions.Function<? super T, ? extends java.lang.Iterable<? extends U>>);
descriptor: (Lio/reactivex/functions/Function;)Lio/reactivex/Flowable;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "mapper is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleFlatMapIterableFlowable
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.single.SingleFlatMapIterableFlowable.<init>:(Lio/reactivex/SingleSource;Lio/reactivex/functions/Function;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Flowable;)Lio/reactivex/Flowable;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 mapper Lio/reactivex/functions/Function<-TT;+Ljava/lang/Iterable<+TU;>;>;
Signature: <U:Ljava/lang/Object;>(Lio/reactivex/functions/Function<-TT;+Ljava/lang/Iterable<+TU;>;>;)Lio/reactivex/Flowable<TU;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
mapper final
public final <U> io.reactivex.Observable<U> flattenAsObservable(io.reactivex.functions.Function<? super T, ? extends java.lang.Iterable<? extends U>>);
descriptor: (Lio/reactivex/functions/Function;)Lio/reactivex/Observable;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "mapper is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleFlatMapIterableObservable
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.single.SingleFlatMapIterableObservable.<init>:(Lio/reactivex/SingleSource;Lio/reactivex/functions/Function;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Observable;)Lio/reactivex/Observable;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 mapper Lio/reactivex/functions/Function<-TT;+Ljava/lang/Iterable<+TU;>;>;
Signature: <U:Ljava/lang/Object;>(Lio/reactivex/functions/Function<-TT;+Ljava/lang/Iterable<+TU;>;>;)Lio/reactivex/Observable<TU;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
mapper final
public final <R> io.reactivex.Observable<R> flatMapObservable(io.reactivex.functions.Function<? super T, ? extends io.reactivex.ObservableSource<? extends R>>);
descriptor: (Lio/reactivex/functions/Function;)Lio/reactivex/Observable;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "mapper is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.mixed.SingleFlatMapObservable
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.mixed.SingleFlatMapObservable.<init>:(Lio/reactivex/SingleSource;Lio/reactivex/functions/Function;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Observable;)Lio/reactivex/Observable;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 mapper Lio/reactivex/functions/Function<-TT;+Lio/reactivex/ObservableSource<+TR;>;>;
Signature: <R:Ljava/lang/Object;>(Lio/reactivex/functions/Function<-TT;+Lio/reactivex/ObservableSource<+TR;>;>;)Lio/reactivex/Observable<TR;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
mapper
public final io.reactivex.Completable flatMapCompletable(io.reactivex.functions.Function<? super T, ? extends io.reactivex.CompletableSource>);
descriptor: (Lio/reactivex/functions/Function;)Lio/reactivex/Completable;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "mapper is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleFlatMapCompletable
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.single.SingleFlatMapCompletable.<init>:(Lio/reactivex/SingleSource;Lio/reactivex/functions/Function;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 mapper Lio/reactivex/functions/Function<-TT;+Lio/reactivex/CompletableSource;>;
Signature: (Lio/reactivex/functions/Function<-TT;+Lio/reactivex/CompletableSource;>;)Lio/reactivex/Completable;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
mapper final
public final T blockingGet();
descriptor: ()Ljava/lang/Object;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=2, locals=2, args_size=1
start local 0 0: new io.reactivex.internal.observers.BlockingMultiObserver
dup
invokespecial io.reactivex.internal.observers.BlockingMultiObserver.<init>:()V
astore 1
start local 1 1: aload 0
aload 1
invokevirtual io.reactivex.Single.subscribe:(Lio/reactivex/SingleObserver;)V
2: aload 1
invokevirtual io.reactivex.internal.observers.BlockingMultiObserver.blockingGet:()Ljava/lang/Object;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactivex/Single<TT;>;
1 3 1 observer Lio/reactivex/internal/observers/BlockingMultiObserver<TT;>;
Signature: ()TT;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
public final <R> io.reactivex.Single<R> lift(io.reactivex.SingleOperator<? extends R, ? super T>);
descriptor: (Lio/reactivex/SingleOperator;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "lift is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleLift
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.single.SingleLift.<init>:(Lio/reactivex/SingleSource;Lio/reactivex/SingleOperator;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 lift Lio/reactivex/SingleOperator<+TR;-TT;>;
Signature: <R:Ljava/lang/Object;>(Lio/reactivex/SingleOperator<+TR;-TT;>;)Lio/reactivex/Single<TR;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
lift final
public final <R> io.reactivex.Single<R> map(io.reactivex.functions.Function<? super T, ? extends R>);
descriptor: (Lio/reactivex/functions/Function;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "mapper is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleMap
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.single.SingleMap.<init>:(Lio/reactivex/SingleSource;Lio/reactivex/functions/Function;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 mapper Lio/reactivex/functions/Function<-TT;+TR;>;
Signature: <R:Ljava/lang/Object;>(Lio/reactivex/functions/Function<-TT;+TR;>;)Lio/reactivex/Single<TR;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
mapper
public final io.reactivex.Single<io.reactivex.Notification<T>> materialize();
descriptor: ()Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=3, locals=1, args_size=1
start local 0 0: new io.reactivex.internal.operators.single.SingleMaterialize
dup
aload 0
invokespecial io.reactivex.internal.operators.single.SingleMaterialize.<init>:(Lio/reactivex/Single;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
Signature: ()Lio/reactivex/Single<Lio/reactivex/Notification<TT;>;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.Experimental()
RuntimeInvisibleTypeAnnotations:
METHOD_RETURN
io.reactivex.annotations.Experimental()
public final io.reactivex.Single<java.lang.Boolean> contains();
descriptor: (Ljava/lang/Object;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic io.reactivex.internal.functions.ObjectHelper.equalsPredicate:()Lio/reactivex/functions/BiPredicate;
invokevirtual io.reactivex.Single.contains:(Ljava/lang/Object;Lio/reactivex/functions/BiPredicate;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
0 1 1 value Ljava/lang/Object;
Signature: (Ljava/lang/Object;)Lio/reactivex/Single<Ljava/lang/Boolean;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
value
public final io.reactivex.Single<java.lang.Boolean> contains(, io.reactivex.functions.BiPredicate<java.lang.Object, java.lang.Object>);
descriptor: (Ljava/lang/Object;Lio/reactivex/functions/BiPredicate;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=5, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 1
ldc "value is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "comparer is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: new io.reactivex.internal.operators.single.SingleContains
dup
aload 0
aload 1
aload 2
invokespecial io.reactivex.internal.operators.single.SingleContains.<init>:(Lio/reactivex/SingleSource;Ljava/lang/Object;Lio/reactivex/functions/BiPredicate;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactivex/Single<TT;>;
0 3 1 value Ljava/lang/Object;
0 3 2 comparer Lio/reactivex/functions/BiPredicate<Ljava/lang/Object;Ljava/lang/Object;>;
Signature: (Ljava/lang/Object;Lio/reactivex/functions/BiPredicate<Ljava/lang/Object;Ljava/lang/Object;>;)Lio/reactivex/Single<Ljava/lang/Boolean;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
value final
comparer final
public final io.reactivex.Flowable<T> mergeWith(io.reactivex.SingleSource<? extends T>);
descriptor: (Lio/reactivex/SingleSource;)Lio/reactivex/Flowable;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic io.reactivex.Single.merge:(Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;)Lio/reactivex/Flowable;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
0 1 1 other Lio/reactivex/SingleSource<+TT;>;
Signature: (Lio/reactivex/SingleSource<+TT;>;)Lio/reactivex/Flowable<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
other
public final io.reactivex.Single<T> observeOn(io.reactivex.Scheduler);
descriptor: (Lio/reactivex/Scheduler;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "scheduler is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleObserveOn
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.single.SingleObserveOn.<init>:(Lio/reactivex/SingleSource;Lio/reactivex/Scheduler;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 scheduler Lio/reactivex/Scheduler;
Signature: (Lio/reactivex/Scheduler;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "custom")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
scheduler final
public final io.reactivex.Single<T> onErrorReturn(io.reactivex.functions.Function<java.lang.Throwable, ? extends T>);
descriptor: (Lio/reactivex/functions/Function;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "resumeFunction is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleOnErrorReturn
dup
aload 0
aload 1
aconst_null
invokespecial io.reactivex.internal.operators.single.SingleOnErrorReturn.<init>:(Lio/reactivex/SingleSource;Lio/reactivex/functions/Function;Ljava/lang/Object;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 resumeFunction Lio/reactivex/functions/Function<Ljava/lang/Throwable;+TT;>;
Signature: (Lio/reactivex/functions/Function<Ljava/lang/Throwable;+TT;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
resumeFunction final
public final io.reactivex.Single<T> onErrorReturnItem(T);
descriptor: (Ljava/lang/Object;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "value is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleOnErrorReturn
dup
aload 0
aconst_null
aload 1
invokespecial io.reactivex.internal.operators.single.SingleOnErrorReturn.<init>:(Lio/reactivex/SingleSource;Lio/reactivex/functions/Function;Ljava/lang/Object;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 value TT;
Signature: (TT;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
value final
public final io.reactivex.Single<T> onErrorResumeNext(io.reactivex.Single<? extends T>);
descriptor: (Lio/reactivex/Single;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "resumeSingleInCaseOfError is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
aload 1
invokestatic io.reactivex.internal.functions.Functions.justFunction:(Ljava/lang/Object;)Lio/reactivex/functions/Function;
invokevirtual io.reactivex.Single.onErrorResumeNext:(Lio/reactivex/functions/Function;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 resumeSingleInCaseOfError Lio/reactivex/Single<+TT;>;
Signature: (Lio/reactivex/Single<+TT;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
resumeSingleInCaseOfError final
public final io.reactivex.Single<T> onErrorResumeNext(io.reactivex.functions.Function<? super java.lang.Throwable, ? extends io.reactivex.SingleSource<? extends T>>);
descriptor: (Lio/reactivex/functions/Function;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "resumeFunctionInCaseOfError is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleResumeNext
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.single.SingleResumeNext.<init>:(Lio/reactivex/SingleSource;Lio/reactivex/functions/Function;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 resumeFunctionInCaseOfError Lio/reactivex/functions/Function<-Ljava/lang/Throwable;+Lio/reactivex/SingleSource<+TT;>;>;
Signature: (Lio/reactivex/functions/Function<-Ljava/lang/Throwable;+Lio/reactivex/SingleSource<+TT;>;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
resumeFunctionInCaseOfError final
public final io.reactivex.Single<T> onTerminateDetach();
descriptor: ()Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=3, locals=1, args_size=1
start local 0 0: new io.reactivex.internal.operators.single.SingleDetach
dup
aload 0
invokespecial io.reactivex.internal.operators.single.SingleDetach.<init>:(Lio/reactivex/SingleSource;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
Signature: ()Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
public final io.reactivex.Flowable<T> repeat();
descriptor: ()Lio/reactivex/Flowable;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.reactivex.Single.toFlowable:()Lio/reactivex/Flowable;
invokevirtual io.reactivex.Flowable.repeat:()Lio/reactivex/Flowable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
Signature: ()Lio/reactivex/Flowable<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
public final io.reactivex.Flowable<T> repeat(long);
descriptor: (J)Lio/reactivex/Flowable;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.reactivex.Single.toFlowable:()Lio/reactivex/Flowable;
lload 1
invokevirtual io.reactivex.Flowable.repeat:(J)Lio/reactivex/Flowable;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
0 1 1 times J
Signature: (J)Lio/reactivex/Flowable<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
times
public final io.reactivex.Flowable<T> repeatWhen(io.reactivex.functions.Function<? super io.reactivex.Flowable<java.lang.Object>, ? extends org.reactivestreams.Publisher<?>>);
descriptor: (Lio/reactivex/functions/Function;)Lio/reactivex/Flowable;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.reactivex.Single.toFlowable:()Lio/reactivex/Flowable;
aload 1
invokevirtual io.reactivex.Flowable.repeatWhen:(Lio/reactivex/functions/Function;)Lio/reactivex/Flowable;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
0 1 1 handler Lio/reactivex/functions/Function<-Lio/reactivex/Flowable<Ljava/lang/Object;>;+Lorg/reactivestreams/Publisher<*>;>;
Signature: (Lio/reactivex/functions/Function<-Lio/reactivex/Flowable<Ljava/lang/Object;>;+Lorg/reactivestreams/Publisher<*>;>;)Lio/reactivex/Flowable<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
handler
public final io.reactivex.Flowable<T> repeatUntil(io.reactivex.functions.BooleanSupplier);
descriptor: (Lio/reactivex/functions/BooleanSupplier;)Lio/reactivex/Flowable;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.reactivex.Single.toFlowable:()Lio/reactivex/Flowable;
aload 1
invokevirtual io.reactivex.Flowable.repeatUntil:(Lio/reactivex/functions/BooleanSupplier;)Lio/reactivex/Flowable;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
0 1 1 stop Lio/reactivex/functions/BooleanSupplier;
Signature: (Lio/reactivex/functions/BooleanSupplier;)Lio/reactivex/Flowable<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
stop
public final io.reactivex.Single<T> retry();
descriptor: ()Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.reactivex.Single.toFlowable:()Lio/reactivex/Flowable;
invokevirtual io.reactivex.Flowable.retry:()Lio/reactivex/Flowable;
invokestatic io.reactivex.Single.toSingle:(Lio/reactivex/Flowable;)Lio/reactivex/Single;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
Signature: ()Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
public final io.reactivex.Single<T> retry(long);
descriptor: (J)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.reactivex.Single.toFlowable:()Lio/reactivex/Flowable;
lload 1
invokevirtual io.reactivex.Flowable.retry:(J)Lio/reactivex/Flowable;
invokestatic io.reactivex.Single.toSingle:(Lio/reactivex/Flowable;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
0 1 1 times J
Signature: (J)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
times
public final io.reactivex.Single<T> retry(io.reactivex.functions.BiPredicate<? super java.lang.Integer, ? super java.lang.Throwable>);
descriptor: (Lio/reactivex/functions/BiPredicate;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.reactivex.Single.toFlowable:()Lio/reactivex/Flowable;
aload 1
invokevirtual io.reactivex.Flowable.retry:(Lio/reactivex/functions/BiPredicate;)Lio/reactivex/Flowable;
invokestatic io.reactivex.Single.toSingle:(Lio/reactivex/Flowable;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
0 1 1 predicate Lio/reactivex/functions/BiPredicate<-Ljava/lang/Integer;-Ljava/lang/Throwable;>;
Signature: (Lio/reactivex/functions/BiPredicate<-Ljava/lang/Integer;-Ljava/lang/Throwable;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
predicate
public final io.reactivex.Single<T> retry(long, io.reactivex.functions.Predicate<? super java.lang.Throwable>);
descriptor: (JLio/reactivex/functions/Predicate;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 3 0: aload 0
invokevirtual io.reactivex.Single.toFlowable:()Lio/reactivex/Flowable;
lload 1
aload 3
invokevirtual io.reactivex.Flowable.retry:(JLio/reactivex/functions/Predicate;)Lio/reactivex/Flowable;
invokestatic io.reactivex.Single.toSingle:(Lio/reactivex/Flowable;)Lio/reactivex/Single;
areturn
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
0 1 1 times J
0 1 3 predicate Lio/reactivex/functions/Predicate<-Ljava/lang/Throwable;>;
Signature: (JLio/reactivex/functions/Predicate<-Ljava/lang/Throwable;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
times
predicate
public final io.reactivex.Single<T> retry(io.reactivex.functions.Predicate<? super java.lang.Throwable>);
descriptor: (Lio/reactivex/functions/Predicate;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.reactivex.Single.toFlowable:()Lio/reactivex/Flowable;
aload 1
invokevirtual io.reactivex.Flowable.retry:(Lio/reactivex/functions/Predicate;)Lio/reactivex/Flowable;
invokestatic io.reactivex.Single.toSingle:(Lio/reactivex/Flowable;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
0 1 1 predicate Lio/reactivex/functions/Predicate<-Ljava/lang/Throwable;>;
Signature: (Lio/reactivex/functions/Predicate<-Ljava/lang/Throwable;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
predicate
public final io.reactivex.Single<T> retryWhen(io.reactivex.functions.Function<? super io.reactivex.Flowable<java.lang.Throwable>, ? extends org.reactivestreams.Publisher<?>>);
descriptor: (Lio/reactivex/functions/Function;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.reactivex.Single.toFlowable:()Lio/reactivex/Flowable;
aload 1
invokevirtual io.reactivex.Flowable.retryWhen:(Lio/reactivex/functions/Function;)Lio/reactivex/Flowable;
invokestatic io.reactivex.Single.toSingle:(Lio/reactivex/Flowable;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
0 1 1 handler Lio/reactivex/functions/Function<-Lio/reactivex/Flowable<Ljava/lang/Throwable;>;+Lorg/reactivestreams/Publisher<*>;>;
Signature: (Lio/reactivex/functions/Function<-Lio/reactivex/Flowable<Ljava/lang/Throwable;>;+Lorg/reactivestreams/Publisher<*>;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
handler
public final io.reactivex.disposables.Disposable subscribe();
descriptor: ()Lio/reactivex/disposables/Disposable;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
getstatic io.reactivex.internal.functions.Functions.ON_ERROR_MISSING:Lio/reactivex/functions/Consumer;
invokevirtual io.reactivex.Single.subscribe:(Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;)Lio/reactivex/disposables/Disposable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.SchedulerSupport(value = "none")
public final io.reactivex.disposables.Disposable subscribe(io.reactivex.functions.BiConsumer<? super T, ? super java.lang.Throwable>);
descriptor: (Lio/reactivex/functions/BiConsumer;)Lio/reactivex/disposables/Disposable;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 1
ldc "onCallback is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.observers.BiConsumerSingleObserver
dup
aload 1
invokespecial io.reactivex.internal.observers.BiConsumerSingleObserver.<init>:(Lio/reactivex/functions/BiConsumer;)V
astore 2
start local 2 2: aload 0
aload 2
invokevirtual io.reactivex.Single.subscribe:(Lio/reactivex/SingleObserver;)V
3: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/reactivex/Single<TT;>;
0 4 1 onCallback Lio/reactivex/functions/BiConsumer<-TT;-Ljava/lang/Throwable;>;
2 4 2 observer Lio/reactivex/internal/observers/BiConsumerSingleObserver<TT;>;
Signature: (Lio/reactivex/functions/BiConsumer<-TT;-Ljava/lang/Throwable;>;)Lio/reactivex/disposables/Disposable;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
onCallback final
public final io.reactivex.disposables.Disposable subscribe(io.reactivex.functions.Consumer<? super T>);
descriptor: (Lio/reactivex/functions/Consumer;)Lio/reactivex/disposables/Disposable;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
getstatic io.reactivex.internal.functions.Functions.ON_ERROR_MISSING:Lio/reactivex/functions/Consumer;
invokevirtual io.reactivex.Single.subscribe:(Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;)Lio/reactivex/disposables/Disposable;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
0 1 1 onSuccess Lio/reactivex/functions/Consumer<-TT;>;
Signature: (Lio/reactivex/functions/Consumer<-TT;>;)Lio/reactivex/disposables/Disposable;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
onSuccess
public final io.reactivex.disposables.Disposable subscribe(io.reactivex.functions.Consumer<? super T>, io.reactivex.functions.Consumer<? super java.lang.Throwable>);
descriptor: (Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;)Lio/reactivex/disposables/Disposable;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 1
ldc "onSuccess is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "onError is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: new io.reactivex.internal.observers.ConsumerSingleObserver
dup
aload 1
aload 2
invokespecial io.reactivex.internal.observers.ConsumerSingleObserver.<init>:(Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;)V
astore 3
start local 3 3: aload 0
aload 3
invokevirtual io.reactivex.Single.subscribe:(Lio/reactivex/SingleObserver;)V
4: aload 3
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/reactivex/Single<TT;>;
0 5 1 onSuccess Lio/reactivex/functions/Consumer<-TT;>;
0 5 2 onError Lio/reactivex/functions/Consumer<-Ljava/lang/Throwable;>;
3 5 3 observer Lio/reactivex/internal/observers/ConsumerSingleObserver<TT;>;
Signature: (Lio/reactivex/functions/Consumer<-TT;>;Lio/reactivex/functions/Consumer<-Ljava/lang/Throwable;>;)Lio/reactivex/disposables/Disposable;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
onSuccess final
onError final
public final void subscribe(io.reactivex.SingleObserver<? super T>);
descriptor: (Lio/reactivex/SingleObserver;)V
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=3, locals=4, args_size=2
start local 0 start local 1 0: aload 1
ldc "observer is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
aload 1
invokestatic io.reactivex.plugins.RxJavaPlugins.onSubscribe:(Lio/reactivex/Single;Lio/reactivex/SingleObserver;)Lio/reactivex/SingleObserver;
astore 1
2: aload 1
ldc "The RxJavaPlugins.onSubscribe hook returned a null SingleObserver. Please check the handler provided to RxJavaPlugins.setOnSingleSubscribe for invalid null returns. Further reading: https://github.com/ReactiveX/RxJava/wiki/Plugins"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
3: aload 0
aload 1
invokevirtual io.reactivex.Single.subscribeActual:(Lio/reactivex/SingleObserver;)V
4: goto 12
StackMap locals:
StackMap stack: java.lang.NullPointerException
5: astore 2
start local 2 6: aload 2
athrow
end local 2 7: StackMap locals:
StackMap stack: java.lang.Throwable
astore 2
start local 2 8: aload 2
invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
9: new java.lang.NullPointerException
dup
ldc "subscribeActual failed"
invokespecial java.lang.NullPointerException.<init>:(Ljava/lang/String;)V
astore 3
start local 3 10: aload 3
aload 2
invokevirtual java.lang.NullPointerException.initCause:(Ljava/lang/Throwable;)Ljava/lang/Throwable;
pop
11: aload 3
athrow
end local 3 end local 2 12: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lio/reactivex/Single<TT;>;
0 13 1 observer Lio/reactivex/SingleObserver<-TT;>;
6 7 2 ex Ljava/lang/NullPointerException;
8 12 2 ex Ljava/lang/Throwable;
10 12 3 npe Ljava/lang/NullPointerException;
Exception table:
from to target type
3 4 5 Class java.lang.NullPointerException
3 4 7 Class java.lang.Throwable
Signature: (Lio/reactivex/SingleObserver<-TT;>;)V
RuntimeVisibleAnnotations:
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
observer
protected abstract void subscribeActual(io.reactivex.SingleObserver<? super T>);
descriptor: (Lio/reactivex/SingleObserver;)V
flags: (0x0404) ACC_PROTECTED, ACC_ABSTRACT
Signature: (Lio/reactivex/SingleObserver<-TT;>;)V
RuntimeInvisibleParameterAnnotations:
0:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
observer
public final <E extends io.reactivex.SingleObserver<? super T>> E subscribeWith();
descriptor: (Lio/reactivex/SingleObserver;)Lio/reactivex/SingleObserver;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokevirtual io.reactivex.Single.subscribe:(Lio/reactivex/SingleObserver;)V
1: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 observer TE;
Signature: <E::Lio/reactivex/SingleObserver<-TT;>;>(TE;)TE;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
observer
public final io.reactivex.Single<T> subscribeOn(io.reactivex.Scheduler);
descriptor: (Lio/reactivex/Scheduler;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "scheduler is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleSubscribeOn
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.single.SingleSubscribeOn.<init>:(Lio/reactivex/SingleSource;Lio/reactivex/Scheduler;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 scheduler Lio/reactivex/Scheduler;
Signature: (Lio/reactivex/Scheduler;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "custom")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
scheduler final
public final io.reactivex.Single<T> takeUntil(io.reactivex.CompletableSource);
descriptor: (Lio/reactivex/CompletableSource;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "other is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
new io.reactivex.internal.operators.completable.CompletableToFlowable
dup
aload 1
invokespecial io.reactivex.internal.operators.completable.CompletableToFlowable.<init>:(Lio/reactivex/CompletableSource;)V
invokevirtual io.reactivex.Single.takeUntil:(Lorg/reactivestreams/Publisher;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 other Lio/reactivex/CompletableSource;
Signature: (Lio/reactivex/CompletableSource;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
other final
public final <E> io.reactivex.Single<T> takeUntil(org.reactivestreams.Publisher<E>);
descriptor: (Lorg/reactivestreams/Publisher;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "other is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleTakeUntil
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.single.SingleTakeUntil.<init>:(Lio/reactivex/SingleSource;Lorg/reactivestreams/Publisher;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 other Lorg/reactivestreams/Publisher<TE;>;
Signature: <E:Ljava/lang/Object;>(Lorg/reactivestreams/Publisher<TE;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
other final
public final <E> io.reactivex.Single<T> takeUntil(io.reactivex.SingleSource<? extends E>);
descriptor: (Lio/reactivex/SingleSource;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "other is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
new io.reactivex.internal.operators.single.SingleToFlowable
dup
aload 1
invokespecial io.reactivex.internal.operators.single.SingleToFlowable.<init>:(Lio/reactivex/SingleSource;)V
invokevirtual io.reactivex.Single.takeUntil:(Lorg/reactivestreams/Publisher;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 other Lio/reactivex/SingleSource<+TE;>;
Signature: <E:Ljava/lang/Object;>(Lio/reactivex/SingleSource<+TE;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
other final
public final io.reactivex.Single<T> timeout(long, java.util.concurrent.TimeUnit);
descriptor: (JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=6, locals=4, args_size=3
start local 0 start local 1 start local 3 0: aload 0
lload 1
aload 3
invokestatic io.reactivex.schedulers.Schedulers.computation:()Lio/reactivex/Scheduler;
aconst_null
invokevirtual io.reactivex.Single.timeout0:(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Lio/reactivex/SingleSource;)Lio/reactivex/Single;
areturn
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
0 1 1 timeout J
0 1 3 unit Ljava/util/concurrent/TimeUnit;
Signature: (JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "io.reactivex:computation")
MethodParameters:
Name Flags
timeout
unit
public final io.reactivex.Single<T> timeout(long, java.util.concurrent.TimeUnit, io.reactivex.Scheduler);
descriptor: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=6, locals=5, args_size=4
start local 0 start local 1 start local 3 start local 4 0: aload 0
lload 1
aload 3
aload 4
aconst_null
invokevirtual io.reactivex.Single.timeout0:(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Lio/reactivex/SingleSource;)Lio/reactivex/Single;
areturn
end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
0 1 1 timeout J
0 1 3 unit Ljava/util/concurrent/TimeUnit;
0 1 4 scheduler Lio/reactivex/Scheduler;
Signature: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "custom")
MethodParameters:
Name Flags
timeout
unit
scheduler
public final io.reactivex.Single<T> timeout(long, java.util.concurrent.TimeUnit, io.reactivex.Scheduler, io.reactivex.SingleSource<? extends T>);
descriptor: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Lio/reactivex/SingleSource;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=6, locals=6, args_size=5
start local 0 start local 1 start local 3 start local 4 start local 5 0: aload 5
ldc "other is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
lload 1
aload 3
aload 4
aload 5
invokevirtual io.reactivex.Single.timeout0:(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Lio/reactivex/SingleSource;)Lio/reactivex/Single;
areturn
end local 5 end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 timeout J
0 2 3 unit Ljava/util/concurrent/TimeUnit;
0 2 4 scheduler Lio/reactivex/Scheduler;
0 2 5 other Lio/reactivex/SingleSource<+TT;>;
Signature: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Lio/reactivex/SingleSource<+TT;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "custom")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
timeout
unit
scheduler
other
public final io.reactivex.Single<T> timeout(long, java.util.concurrent.TimeUnit, io.reactivex.SingleSource<? extends T>);
descriptor: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/SingleSource;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=6, locals=5, args_size=4
start local 0 start local 1 start local 3 start local 4 0: aload 4
ldc "other is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
lload 1
aload 3
invokestatic io.reactivex.schedulers.Schedulers.computation:()Lio/reactivex/Scheduler;
aload 4
invokevirtual io.reactivex.Single.timeout0:(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Lio/reactivex/SingleSource;)Lio/reactivex/Single;
areturn
end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 timeout J
0 2 3 unit Ljava/util/concurrent/TimeUnit;
0 2 4 other Lio/reactivex/SingleSource<+TT;>;
Signature: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/SingleSource<+TT;>;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "io.reactivex:computation")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
timeout
unit
other
private io.reactivex.Single<T> timeout0(long, java.util.concurrent.TimeUnit, io.reactivex.Scheduler, io.reactivex.SingleSource<? extends T>);
descriptor: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Lio/reactivex/SingleSource;)Lio/reactivex/Single;
flags: (0x0002) ACC_PRIVATE
Code:
stack=8, locals=6, args_size=5
start local 0 start local 1 start local 3 start local 4 start local 5 0: aload 3
ldc "unit is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 4
ldc "scheduler is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: new io.reactivex.internal.operators.single.SingleTimeout
dup
aload 0
lload 1
aload 3
aload 4
aload 5
invokespecial io.reactivex.internal.operators.single.SingleTimeout.<init>:(Lio/reactivex/SingleSource;JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Lio/reactivex/SingleSource;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 5 end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactivex/Single<TT;>;
0 3 1 timeout J
0 3 3 unit Ljava/util/concurrent/TimeUnit;
0 3 4 scheduler Lio/reactivex/Scheduler;
0 3 5 other Lio/reactivex/SingleSource<+TT;>;
Signature: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Lio/reactivex/SingleSource<+TT;>;)Lio/reactivex/Single<TT;>;
MethodParameters:
Name Flags
timeout final
unit final
scheduler final
other final
public final <R> R to(io.reactivex.functions.Function<? super io.reactivex.Single<T>, R>);
descriptor: (Lio/reactivex/functions/Function;)Ljava/lang/Object;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 1
ldc "convert is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast io.reactivex.functions.Function
aload 0
invokeinterface io.reactivex.functions.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
1: areturn
2: StackMap locals:
StackMap stack: java.lang.Throwable
astore 2
start local 2 3: aload 2
invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
4: aload 2
invokestatic io.reactivex.internal.util.ExceptionHelper.wrapOrThrow:(Ljava/lang/Throwable;)Ljava/lang/RuntimeException;
athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/reactivex/Single<TT;>;
0 5 1 convert Lio/reactivex/functions/Function<-Lio/reactivex/Single<TT;>;TR;>;
3 5 2 ex Ljava/lang/Throwable;
Exception table:
from to target type
0 1 2 Class java.lang.Throwable
Signature: <R:Ljava/lang/Object;>(Lio/reactivex/functions/Function<-Lio/reactivex/Single<TT;>;TR;>;)TR;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
convert
public final io.reactivex.Completable toCompletable();
descriptor: ()Lio/reactivex/Completable;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=3, locals=1, args_size=1
start local 0 0: new io.reactivex.internal.operators.completable.CompletableFromSingle
dup
aload 0
invokespecial io.reactivex.internal.operators.completable.CompletableFromSingle.<init>:(Lio/reactivex/SingleSource;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
java.lang.Deprecated()
public final io.reactivex.Completable ignoreElement();
descriptor: ()Lio/reactivex/Completable;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=3, locals=1, args_size=1
start local 0 0: new io.reactivex.internal.operators.completable.CompletableFromSingle
dup
aload 0
invokespecial io.reactivex.internal.operators.completable.CompletableFromSingle.<init>:(Lio/reactivex/SingleSource;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Completable;)Lio/reactivex/Completable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
public final io.reactivex.Flowable<T> toFlowable();
descriptor: ()Lio/reactivex/Flowable;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
instanceof io.reactivex.internal.fuseable.FuseToFlowable
ifeq 2
1: aload 0
checkcast io.reactivex.internal.fuseable.FuseToFlowable
invokeinterface io.reactivex.internal.fuseable.FuseToFlowable.fuseToFlowable:()Lio/reactivex/Flowable;
areturn
2: StackMap locals:
StackMap stack:
new io.reactivex.internal.operators.single.SingleToFlowable
dup
aload 0
invokespecial io.reactivex.internal.operators.single.SingleToFlowable.<init>:(Lio/reactivex/SingleSource;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Flowable;)Lio/reactivex/Flowable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactivex/Single<TT;>;
Signature: ()Lio/reactivex/Flowable<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.FULL:Lio/reactivex/annotations/BackpressureKind;)
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
public final java.util.concurrent.Future<T> toFuture();
descriptor: ()Ljava/util/concurrent/Future;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
new io.reactivex.internal.observers.FutureSingleObserver
dup
invokespecial io.reactivex.internal.observers.FutureSingleObserver.<init>:()V
invokevirtual io.reactivex.Single.subscribeWith:(Lio/reactivex/SingleObserver;)Lio/reactivex/SingleObserver;
checkcast java.util.concurrent.Future
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
Signature: ()Ljava/util/concurrent/Future<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
public final io.reactivex.Maybe<T> toMaybe();
descriptor: ()Lio/reactivex/Maybe;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
instanceof io.reactivex.internal.fuseable.FuseToMaybe
ifeq 2
1: aload 0
checkcast io.reactivex.internal.fuseable.FuseToMaybe
invokeinterface io.reactivex.internal.fuseable.FuseToMaybe.fuseToMaybe:()Lio/reactivex/Maybe;
areturn
2: StackMap locals:
StackMap stack:
new io.reactivex.internal.operators.maybe.MaybeFromSingle
dup
aload 0
invokespecial io.reactivex.internal.operators.maybe.MaybeFromSingle.<init>:(Lio/reactivex/SingleSource;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactivex/Single<TT;>;
Signature: ()Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
public final io.reactivex.Observable<T> toObservable();
descriptor: ()Lio/reactivex/Observable;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
instanceof io.reactivex.internal.fuseable.FuseToObservable
ifeq 2
1: aload 0
checkcast io.reactivex.internal.fuseable.FuseToObservable
invokeinterface io.reactivex.internal.fuseable.FuseToObservable.fuseToObservable:()Lio/reactivex/Observable;
areturn
2: StackMap locals:
StackMap stack:
new io.reactivex.internal.operators.single.SingleToObservable
dup
aload 0
invokespecial io.reactivex.internal.operators.single.SingleToObservable.<init>:(Lio/reactivex/SingleSource;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Observable;)Lio/reactivex/Observable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactivex/Single<TT;>;
Signature: ()Lio/reactivex/Observable<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
public final io.reactivex.Single<T> unsubscribeOn(io.reactivex.Scheduler);
descriptor: (Lio/reactivex/Scheduler;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "scheduler is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.reactivex.internal.operators.single.SingleUnsubscribeOn
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.single.SingleUnsubscribeOn.<init>:(Lio/reactivex/SingleSource;Lio/reactivex/Scheduler;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Single<TT;>;
0 2 1 scheduler Lio/reactivex/Scheduler;
Signature: (Lio/reactivex/Scheduler;)Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "custom")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
scheduler final
public final <U, R> io.reactivex.Single<R> zipWith(io.reactivex.SingleSource<U>, io.reactivex.functions.BiFunction<? super T, ? super U, ? extends R>);
descriptor: (Lio/reactivex/SingleSource;Lio/reactivex/functions/BiFunction;)Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
invokestatic io.reactivex.Single.zip:(Lio/reactivex/SingleSource;Lio/reactivex/SingleSource;Lio/reactivex/functions/BiFunction;)Lio/reactivex/Single;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Single<TT;>;
0 1 1 other Lio/reactivex/SingleSource<TU;>;
0 1 2 zipper Lio/reactivex/functions/BiFunction<-TT;-TU;+TR;>;
Signature: <U:Ljava/lang/Object;R:Ljava/lang/Object;>(Lio/reactivex/SingleSource<TU;>;Lio/reactivex/functions/BiFunction<-TT;-TU;+TR;>;)Lio/reactivex/Single<TR;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
other
zipper
public final io.reactivex.observers.TestObserver<T> test();
descriptor: ()Lio/reactivex/observers/TestObserver;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=2, locals=2, args_size=1
start local 0 0: new io.reactivex.observers.TestObserver
dup
invokespecial io.reactivex.observers.TestObserver.<init>:()V
astore 1
start local 1 1: aload 0
aload 1
invokevirtual io.reactivex.Single.subscribe:(Lio/reactivex/SingleObserver;)V
2: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactivex/Single<TT;>;
1 3 1 to Lio/reactivex/observers/TestObserver<TT;>;
Signature: ()Lio/reactivex/observers/TestObserver<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
public final io.reactivex.observers.TestObserver<T> test(boolean);
descriptor: (Z)Lio/reactivex/observers/TestObserver;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: new io.reactivex.observers.TestObserver
dup
invokespecial io.reactivex.observers.TestObserver.<init>:()V
astore 2
start local 2 1: iload 1
ifeq 3
2: aload 2
invokevirtual io.reactivex.observers.TestObserver.cancel:()V
3: StackMap locals: io.reactivex.observers.TestObserver
StackMap stack:
aload 0
aload 2
invokevirtual io.reactivex.Single.subscribe:(Lio/reactivex/SingleObserver;)V
4: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/reactivex/Single<TT;>;
0 5 1 cancelled Z
1 5 2 to Lio/reactivex/observers/TestObserver<TT;>;
Signature: (Z)Lio/reactivex/observers/TestObserver<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
cancelled
private static <T> io.reactivex.Single<T> toSingle(io.reactivex.Flowable<T>);
descriptor: (Lio/reactivex/Flowable;)Lio/reactivex/Single;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: new io.reactivex.internal.operators.flowable.FlowableSingleSingle
dup
aload 0
aconst_null
invokespecial io.reactivex.internal.operators.flowable.FlowableSingleSingle.<init>:(Lio/reactivex/Flowable;Ljava/lang/Object;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Single;)Lio/reactivex/Single;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 source Lio/reactivex/Flowable<TT;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/Flowable<TT;>;)Lio/reactivex/Single<TT;>;
MethodParameters:
Name Flags
source
}
Signature: <T:Ljava/lang/Object;>Ljava/lang/Object;Lio/reactivex/SingleSource<TT;>;
SourceFile: "Single.java"
