public abstract class io.reactivex.Maybe<T> implements io.reactivex.MaybeSource<T>
minor version: 0
major version: 59
flags: flags: (0x0421) ACC_PUBLIC, ACC_SUPER, ACC_ABSTRACT
this_class: io.reactivex.Maybe
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/Maybe<TT;>;
public static <T> io.reactivex.Maybe<T> amb(java.lang.Iterable<? extends io.reactivex.MaybeSource<? extends T>>);
descriptor: (Ljava/lang/Iterable;)Lio/reactivex/Maybe;
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.maybe.MaybeAmb
dup
aconst_null
aload 0
invokespecial io.reactivex.internal.operators.maybe.MaybeAmb.<init>:([Lio/reactivex/MaybeSource;Ljava/lang/Iterable;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 sources Ljava/lang/Iterable<+Lio/reactivex/MaybeSource<+TT;>;>;
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Iterable<+Lio/reactivex/MaybeSource<+TT;>;>;)Lio/reactivex/Maybe<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.Maybe<T> ambArray(io.reactivex.MaybeSource<? extends T>[]);
descriptor: ([Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe;
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.Maybe.empty:()Lio/reactivex/Maybe;
areturn
2: StackMap locals:
StackMap stack:
aload 0
arraylength
iconst_1
if_icmpne 4
3: aload 0
iconst_0
aaload
invokestatic io.reactivex.Maybe.wrap:(Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe;
areturn
4: StackMap locals:
StackMap stack:
new io.reactivex.internal.operators.maybe.MaybeAmb
dup
aload 0
aconst_null
invokespecial io.reactivex.internal.operators.maybe.MaybeAmb.<init>:([Lio/reactivex/MaybeSource;Ljava/lang/Iterable;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 sources [Lio/reactivex/MaybeSource;
Signature: <T:Ljava/lang/Object;>([Lio/reactivex/MaybeSource<+TT;>;)Lio/reactivex/Maybe<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.MaybeSource<? extends T>>);
descriptor: (Ljava/lang/Iterable;)Lio/reactivex/Flowable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, 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.maybe.MaybeConcatIterable
dup
aload 0
invokespecial io.reactivex.internal.operators.maybe.MaybeConcatIterable.<init>:(Ljava/lang/Iterable;)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 Ljava/lang/Iterable<+Lio/reactivex/MaybeSource<+TT;>;>;
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Iterable<+Lio/reactivex/MaybeSource<+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> concat(io.reactivex.MaybeSource<? extends T>, io.reactivex.MaybeSource<? extends T>);
descriptor: (Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)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.MaybeSource
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
invokestatic io.reactivex.Maybe.concatArray:([Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 source1 Lio/reactivex/MaybeSource<+TT;>;
0 3 1 source2 Lio/reactivex/MaybeSource<+TT;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/MaybeSource<+TT;>;Lio/reactivex/MaybeSource<+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
source1
source2
public static <T> io.reactivex.Flowable<T> concat(io.reactivex.MaybeSource<? extends T>, io.reactivex.MaybeSource<? extends T>, io.reactivex.MaybeSource<? extends T>);
descriptor: (Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)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.MaybeSource
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
dup
iconst_2
aload 2
aastore
invokestatic io.reactivex.Maybe.concatArray:([Lio/reactivex/MaybeSource;)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/MaybeSource<+TT;>;
0 4 1 source2 Lio/reactivex/MaybeSource<+TT;>;
0 4 2 source3 Lio/reactivex/MaybeSource<+TT;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/MaybeSource<+TT;>;Lio/reactivex/MaybeSource<+TT;>;Lio/reactivex/MaybeSource<+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
source1
source2
source3
public static <T> io.reactivex.Flowable<T> concat(io.reactivex.MaybeSource<? extends T>, io.reactivex.MaybeSource<? extends T>, io.reactivex.MaybeSource<? extends T>, io.reactivex.MaybeSource<? extends T>);
descriptor: (Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)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.MaybeSource
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.Maybe.concatArray:([Lio/reactivex/MaybeSource;)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/MaybeSource<+TT;>;
0 5 1 source2 Lio/reactivex/MaybeSource<+TT;>;
0 5 2 source3 Lio/reactivex/MaybeSource<+TT;>;
0 5 3 source4 Lio/reactivex/MaybeSource<+TT;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/MaybeSource<+TT;>;Lio/reactivex/MaybeSource<+TT;>;Lio/reactivex/MaybeSource<+TT;>;Lio/reactivex/MaybeSource<+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
source1
source2
source3
source4
public static <T> io.reactivex.Flowable<T> concat(org.reactivestreams.Publisher<? extends io.reactivex.MaybeSource<? 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.Maybe.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/MaybeSource<+TT;>;>;
Signature: <T:Ljava/lang/Object;>(Lorg/reactivestreams/Publisher<+Lio/reactivex/MaybeSource<+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
sources
public static <T> io.reactivex.Flowable<T> concat(org.reactivestreams.Publisher<? extends io.reactivex.MaybeSource<? 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.maybe.MaybeToPublisher.instance:()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/MaybeSource<+TT;>;>;
0 3 1 prefetch I
Signature: <T:Ljava/lang/Object;>(Lorg/reactivestreams/Publisher<+Lio/reactivex/MaybeSource<+TT;>;>;I)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
prefetch
public static <T> io.reactivex.Flowable<T> concatArray(io.reactivex.MaybeSource<? extends T>[]);
descriptor: ([Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable;
flags: (0x0089) ACC_PUBLIC, ACC_STATIC, ACC_VARARGS
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: aload 0
arraylength
ifne 3
2: invokestatic io.reactivex.Flowable.empty:()Lio/reactivex/Flowable;
areturn
3: StackMap locals:
StackMap stack:
aload 0
arraylength
iconst_1
if_icmpne 5
4: new io.reactivex.internal.operators.maybe.MaybeToFlowable
dup
aload 0
iconst_0
aaload
invokespecial io.reactivex.internal.operators.maybe.MaybeToFlowable.<init>:(Lio/reactivex/MaybeSource;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Flowable;)Lio/reactivex/Flowable;
areturn
5: StackMap locals:
StackMap stack:
new io.reactivex.internal.operators.maybe.MaybeConcatArray
dup
aload 0
invokespecial io.reactivex.internal.operators.maybe.MaybeConcatArray.<init>:([Lio/reactivex/MaybeSource;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Flowable;)Lio/reactivex/Flowable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 sources [Lio/reactivex/MaybeSource;
Signature: <T:Ljava/lang/Object;>([Lio/reactivex/MaybeSource<+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> concatArrayDelayError(io.reactivex.MaybeSource<? extends T>[]);
descriptor: ([Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable;
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.Flowable.empty:()Lio/reactivex/Flowable;
areturn
2: StackMap locals:
StackMap stack:
aload 0
arraylength
iconst_1
if_icmpne 4
3: new io.reactivex.internal.operators.maybe.MaybeToFlowable
dup
aload 0
iconst_0
aaload
invokespecial io.reactivex.internal.operators.maybe.MaybeToFlowable.<init>:(Lio/reactivex/MaybeSource;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Flowable;)Lio/reactivex/Flowable;
areturn
4: StackMap locals:
StackMap stack:
new io.reactivex.internal.operators.maybe.MaybeConcatArrayDelayError
dup
aload 0
invokespecial io.reactivex.internal.operators.maybe.MaybeConcatArrayDelayError.<init>:([Lio/reactivex/MaybeSource;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Flowable;)Lio/reactivex/Flowable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 sources [Lio/reactivex/MaybeSource;
Signature: <T:Ljava/lang/Object;>([Lio/reactivex/MaybeSource<+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
sources
public static <T> io.reactivex.Flowable<T> concatArrayEager(io.reactivex.MaybeSource<? extends T>[]);
descriptor: ([Lio/reactivex/MaybeSource;)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.maybe.MaybeToPublisher.instance:()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/MaybeSource;
Signature: <T:Ljava/lang/Object;>([Lio/reactivex/MaybeSource<+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
sources
public static <T> io.reactivex.Flowable<T> concatDelayError(java.lang.Iterable<? extends io.reactivex.MaybeSource<? 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
ldc "sources 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.Flowable.fromIterable:(Ljava/lang/Iterable;)Lio/reactivex/Flowable;
invokestatic io.reactivex.internal.operators.maybe.MaybeToPublisher.instance:()Lio/reactivex/functions/Function;
invokevirtual io.reactivex.Flowable.concatMapDelayError:(Lio/reactivex/functions/Function;)Lio/reactivex/Flowable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 sources Ljava/lang/Iterable<+Lio/reactivex/MaybeSource<+TT;>;>;
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Iterable<+Lio/reactivex/MaybeSource<+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> concatDelayError(org.reactivestreams.Publisher<? extends io.reactivex.MaybeSource<? 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.maybe.MaybeToPublisher.instance:()Lio/reactivex/functions/Function;
invokevirtual io.reactivex.Flowable.concatMapDelayError:(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/MaybeSource<+TT;>;>;
Signature: <T:Ljava/lang/Object;>(Lorg/reactivestreams/Publisher<+Lio/reactivex/MaybeSource<+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
sources
public static <T> io.reactivex.Flowable<T> concatEager(java.lang.Iterable<? extends io.reactivex.MaybeSource<? 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.maybe.MaybeToPublisher.instance:()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/MaybeSource<+TT;>;>;
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Iterable<+Lio/reactivex/MaybeSource<+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
sources
public static <T> io.reactivex.Flowable<T> concatEager(org.reactivestreams.Publisher<? extends io.reactivex.MaybeSource<? 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.maybe.MaybeToPublisher.instance:()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/MaybeSource<+TT;>;>;
Signature: <T:Ljava/lang/Object;>(Lorg/reactivestreams/Publisher<+Lio/reactivex/MaybeSource<+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
sources
public static <T> io.reactivex.Maybe<T> create(io.reactivex.MaybeOnSubscribe<T>);
descriptor: (Lio/reactivex/MaybeOnSubscribe;)Lio/reactivex/Maybe;
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: new io.reactivex.internal.operators.maybe.MaybeCreate
dup
aload 0
invokespecial io.reactivex.internal.operators.maybe.MaybeCreate.<init>:(Lio/reactivex/MaybeOnSubscribe;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 onSubscribe Lio/reactivex/MaybeOnSubscribe<TT;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/MaybeOnSubscribe<TT;>;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
onSubscribe
public static <T> io.reactivex.Maybe<T> defer(java.util.concurrent.Callable<? extends io.reactivex.MaybeSource<? extends T>>);
descriptor: (Ljava/util/concurrent/Callable;)Lio/reactivex/Maybe;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ldc "maybeSupplier 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.MaybeDefer
dup
aload 0
invokespecial io.reactivex.internal.operators.maybe.MaybeDefer.<init>:(Ljava/util/concurrent/Callable;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 maybeSupplier Ljava/util/concurrent/Callable<+Lio/reactivex/MaybeSource<+TT;>;>;
Signature: <T:Ljava/lang/Object;>(Ljava/util/concurrent/Callable<+Lio/reactivex/MaybeSource<+TT;>;>;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
maybeSupplier final
public static <T> io.reactivex.Maybe<T> empty();
descriptor: ()Lio/reactivex/Maybe;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: getstatic io.reactivex.internal.operators.maybe.MaybeEmpty.INSTANCE:Lio/reactivex/internal/operators/maybe/MaybeEmpty;
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
areturn
LocalVariableTable:
Start End Slot Name Signature
Signature: <T:Ljava/lang/Object;>()Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
public static <T> io.reactivex.Maybe<T> error(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)Lio/reactivex/Maybe;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, 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: new io.reactivex.internal.operators.maybe.MaybeError
dup
aload 0
invokespecial io.reactivex.internal.operators.maybe.MaybeError.<init>:(Ljava/lang/Throwable;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
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/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
exception
public static <T> io.reactivex.Maybe<T> error(java.util.concurrent.Callable<? extends java.lang.Throwable>);
descriptor: (Ljava/util/concurrent/Callable;)Lio/reactivex/Maybe;
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.maybe.MaybeErrorCallable
dup
aload 0
invokespecial io.reactivex.internal.operators.maybe.MaybeErrorCallable.<init>:(Ljava/util/concurrent/Callable;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 supplier Ljava/util/concurrent/Callable<+Ljava/lang/Throwable;>;
Signature: <T:Ljava/lang/Object;>(Ljava/util/concurrent/Callable<+Ljava/lang/Throwable;>;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
supplier
public static <T> io.reactivex.Maybe<T> fromAction(io.reactivex.functions.Action);
descriptor: (Lio/reactivex/functions/Action;)Lio/reactivex/Maybe;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ldc "run 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.MaybeFromAction
dup
aload 0
invokespecial io.reactivex.internal.operators.maybe.MaybeFromAction.<init>:(Lio/reactivex/functions/Action;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 run Lio/reactivex/functions/Action;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/functions/Action;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
run final
public static <T> io.reactivex.Maybe<T> fromCompletable(io.reactivex.CompletableSource);
descriptor: (Lio/reactivex/CompletableSource;)Lio/reactivex/Maybe;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ldc "completableSource 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.MaybeFromCompletable
dup
aload 0
invokespecial io.reactivex.internal.operators.maybe.MaybeFromCompletable.<init>:(Lio/reactivex/CompletableSource;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 completableSource Lio/reactivex/CompletableSource;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/CompletableSource;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
completableSource
public static <T> io.reactivex.Maybe<T> fromSingle(io.reactivex.SingleSource<T>);
descriptor: (Lio/reactivex/SingleSource;)Lio/reactivex/Maybe;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ldc "singleSource 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.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 2 0 singleSource Lio/reactivex/SingleSource<TT;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/SingleSource<TT;>;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
singleSource
public static <T> io.reactivex.Maybe<T> fromCallable(java.util.concurrent.Callable<? extends T>);
descriptor: (Ljava/util/concurrent/Callable;)Lio/reactivex/Maybe;
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.maybe.MaybeFromCallable
dup
aload 0
invokespecial io.reactivex.internal.operators.maybe.MaybeFromCallable.<init>:(Ljava/util/concurrent/Callable;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
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/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
RuntimeInvisibleParameterAnnotations:
0:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
callable final
public static <T> io.reactivex.Maybe<T> fromFuture(java.util.concurrent.Future<? extends T>);
descriptor: (Ljava/util/concurrent/Future;)Lio/reactivex/Maybe;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=1, args_size=1
start local 0 0: aload 0
ldc "future 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.MaybeFromFuture
dup
aload 0
lconst_0
aconst_null
invokespecial io.reactivex.internal.operators.maybe.MaybeFromFuture.<init>:(Ljava/util/concurrent/Future;JLjava/util/concurrent/TimeUnit;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 future Ljava/util/concurrent/Future<+TT;>;
Signature: <T:Ljava/lang/Object;>(Ljava/util/concurrent/Future<+TT;>;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
future
public static <T> io.reactivex.Maybe<T> fromFuture(java.util.concurrent.Future<? extends T>, long, java.util.concurrent.TimeUnit);
descriptor: (Ljava/util/concurrent/Future;JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Maybe;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=4, args_size=3
start local 0 start local 1 start local 3 0: aload 0
ldc "future is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 3
ldc "unit 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.maybe.MaybeFromFuture
dup
aload 0
lload 1
aload 3
invokespecial io.reactivex.internal.operators.maybe.MaybeFromFuture.<init>:(Ljava/util/concurrent/Future;JLjava/util/concurrent/TimeUnit;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
areturn
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 future Ljava/util/concurrent/Future<+TT;>;
0 3 1 timeout J
0 3 3 unit Ljava/util/concurrent/TimeUnit;
Signature: <T:Ljava/lang/Object;>(Ljava/util/concurrent/Future<+TT;>;JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
future
timeout
unit
public static <T> io.reactivex.Maybe<T> fromRunnable(java.lang.Runnable);
descriptor: (Ljava/lang/Runnable;)Lio/reactivex/Maybe;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ldc "run 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.MaybeFromRunnable
dup
aload 0
invokespecial io.reactivex.internal.operators.maybe.MaybeFromRunnable.<init>:(Ljava/lang/Runnable;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 run Ljava/lang/Runnable;
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Runnable;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
run final
public static <T> io.reactivex.Maybe<T> just(T);
descriptor: (Ljava/lang/Object;)Lio/reactivex/Maybe;
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.maybe.MaybeJust
dup
aload 0
invokespecial io.reactivex.internal.operators.maybe.MaybeJust.<init>:(Ljava/lang/Object;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 item TT;
Signature: <T:Ljava/lang/Object;>(TT;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
item
public static <T> io.reactivex.Flowable<T> merge(java.lang.Iterable<? extends io.reactivex.MaybeSource<? 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.Maybe.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/MaybeSource<+TT;>;>;
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Iterable<+Lio/reactivex/MaybeSource<+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
sources
public static <T> io.reactivex.Flowable<T> merge(org.reactivestreams.Publisher<? extends io.reactivex.MaybeSource<? 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
ldc 2147483647
invokestatic io.reactivex.Maybe.merge:(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/MaybeSource<+TT;>;>;
Signature: <T:Ljava/lang/Object;>(Lorg/reactivestreams/Publisher<+Lio/reactivex/MaybeSource<+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
sources
public static <T> io.reactivex.Flowable<T> merge(org.reactivestreams.Publisher<? extends io.reactivex.MaybeSource<? extends T>>, int);
descriptor: (Lorg/reactivestreams/Publisher;I)Lio/reactivex/Flowable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=7, locals=2, args_size=2
start local 0 start local 1 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: iload 1
ldc "maxConcurrency"
invokestatic io.reactivex.internal.functions.ObjectHelper.verifyPositive:(ILjava/lang/String;)I
pop
2: new io.reactivex.internal.operators.flowable.FlowableFlatMapPublisher
dup
aload 0
invokestatic io.reactivex.internal.operators.maybe.MaybeToPublisher.instance:()Lio/reactivex/functions/Function;
iconst_0
iload 1
iconst_1
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 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 sources Lorg/reactivestreams/Publisher<+Lio/reactivex/MaybeSource<+TT;>;>;
0 3 1 maxConcurrency I
Signature: <T:Ljava/lang/Object;>(Lorg/reactivestreams/Publisher<+Lio/reactivex/MaybeSource<+TT;>;>;I)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
maxConcurrency
public static <T> io.reactivex.Maybe<T> merge(io.reactivex.MaybeSource<? extends io.reactivex.MaybeSource<? extends T>>);
descriptor: (Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe;
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.maybe.MaybeFlatten
dup
aload 0
invokestatic io.reactivex.internal.functions.Functions.identity:()Lio/reactivex/functions/Function;
invokespecial io.reactivex.internal.operators.maybe.MaybeFlatten.<init>:(Lio/reactivex/MaybeSource;Lio/reactivex/functions/Function;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 source Lio/reactivex/MaybeSource<+Lio/reactivex/MaybeSource<+TT;>;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/MaybeSource<+Lio/reactivex/MaybeSource<+TT;>;>;)Lio/reactivex/Maybe<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.MaybeSource<? extends T>, io.reactivex.MaybeSource<? extends T>);
descriptor: (Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)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.MaybeSource
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
invokestatic io.reactivex.Maybe.mergeArray:([Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 source1 Lio/reactivex/MaybeSource<+TT;>;
0 3 1 source2 Lio/reactivex/MaybeSource<+TT;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/MaybeSource<+TT;>;Lio/reactivex/MaybeSource<+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
source1
source2
public static <T> io.reactivex.Flowable<T> merge(io.reactivex.MaybeSource<? extends T>, io.reactivex.MaybeSource<? extends T>, io.reactivex.MaybeSource<? extends T>);
descriptor: (Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)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.MaybeSource
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
dup
iconst_2
aload 2
aastore
invokestatic io.reactivex.Maybe.mergeArray:([Lio/reactivex/MaybeSource;)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/MaybeSource<+TT;>;
0 4 1 source2 Lio/reactivex/MaybeSource<+TT;>;
0 4 2 source3 Lio/reactivex/MaybeSource<+TT;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/MaybeSource<+TT;>;Lio/reactivex/MaybeSource<+TT;>;Lio/reactivex/MaybeSource<+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
source1
source2
source3
public static <T> io.reactivex.Flowable<T> merge(io.reactivex.MaybeSource<? extends T>, io.reactivex.MaybeSource<? extends T>, io.reactivex.MaybeSource<? extends T>, io.reactivex.MaybeSource<? extends T>);
descriptor: (Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)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.MaybeSource
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.Maybe.mergeArray:([Lio/reactivex/MaybeSource;)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/MaybeSource<+TT;>;
0 5 1 source2 Lio/reactivex/MaybeSource<+TT;>;
0 5 2 source3 Lio/reactivex/MaybeSource<+TT;>;
0 5 3 source4 Lio/reactivex/MaybeSource<+TT;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/MaybeSource<+TT;>;Lio/reactivex/MaybeSource<+TT;>;Lio/reactivex/MaybeSource<+TT;>;Lio/reactivex/MaybeSource<+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
source1
source2
source3
source4
public static <T> io.reactivex.Flowable<T> mergeArray(io.reactivex.MaybeSource<? extends T>[]);
descriptor: ([Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable;
flags: (0x0089) ACC_PUBLIC, ACC_STATIC, ACC_VARARGS
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: aload 0
arraylength
ifne 3
2: invokestatic io.reactivex.Flowable.empty:()Lio/reactivex/Flowable;
areturn
3: StackMap locals:
StackMap stack:
aload 0
arraylength
iconst_1
if_icmpne 5
4: new io.reactivex.internal.operators.maybe.MaybeToFlowable
dup
aload 0
iconst_0
aaload
invokespecial io.reactivex.internal.operators.maybe.MaybeToFlowable.<init>:(Lio/reactivex/MaybeSource;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Flowable;)Lio/reactivex/Flowable;
areturn
5: StackMap locals:
StackMap stack:
new io.reactivex.internal.operators.maybe.MaybeMergeArray
dup
aload 0
invokespecial io.reactivex.internal.operators.maybe.MaybeMergeArray.<init>:([Lio/reactivex/MaybeSource;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Flowable;)Lio/reactivex/Flowable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 sources [Lio/reactivex/MaybeSource;
Signature: <T:Ljava/lang/Object;>([Lio/reactivex/MaybeSource<+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> mergeArrayDelayError(io.reactivex.MaybeSource<? extends T>[]);
descriptor: ([Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable;
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.Flowable.empty:()Lio/reactivex/Flowable;
areturn
2: StackMap locals:
StackMap stack:
aload 0
invokestatic io.reactivex.Flowable.fromArray:([Ljava/lang/Object;)Lio/reactivex/Flowable;
invokestatic io.reactivex.internal.operators.maybe.MaybeToPublisher.instance:()Lio/reactivex/functions/Function;
iconst_1
aload 0
arraylength
invokevirtual io.reactivex.Flowable.flatMap:(Lio/reactivex/functions/Function;ZI)Lio/reactivex/Flowable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 sources [Lio/reactivex/MaybeSource;
Signature: <T:Ljava/lang/Object;>([Lio/reactivex/MaybeSource<+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
sources
public static <T> io.reactivex.Flowable<T> mergeDelayError(java.lang.Iterable<? extends io.reactivex.MaybeSource<? extends T>>);
descriptor: (Ljava/lang/Iterable;)Lio/reactivex/Flowable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, 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.maybe.MaybeToPublisher.instance:()Lio/reactivex/functions/Function;
iconst_1
invokevirtual io.reactivex.Flowable.flatMap:(Lio/reactivex/functions/Function;Z)Lio/reactivex/Flowable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 sources Ljava/lang/Iterable<+Lio/reactivex/MaybeSource<+TT;>;>;
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Iterable<+Lio/reactivex/MaybeSource<+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
sources
public static <T> io.reactivex.Flowable<T> mergeDelayError(org.reactivestreams.Publisher<? extends io.reactivex.MaybeSource<? 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
ldc 2147483647
invokestatic io.reactivex.Maybe.mergeDelayError:(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/MaybeSource<+TT;>;>;
Signature: <T:Ljava/lang/Object;>(Lorg/reactivestreams/Publisher<+Lio/reactivex/MaybeSource<+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
sources
public static <T> io.reactivex.Flowable<T> mergeDelayError(org.reactivestreams.Publisher<? extends io.reactivex.MaybeSource<? extends T>>, int);
descriptor: (Lorg/reactivestreams/Publisher;I)Lio/reactivex/Flowable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=7, locals=2, args_size=2
start local 0 start local 1 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: iload 1
ldc "maxConcurrency"
invokestatic io.reactivex.internal.functions.ObjectHelper.verifyPositive:(ILjava/lang/String;)I
pop
2: new io.reactivex.internal.operators.flowable.FlowableFlatMapPublisher
dup
aload 0
invokestatic io.reactivex.internal.operators.maybe.MaybeToPublisher.instance:()Lio/reactivex/functions/Function;
iconst_1
iload 1
iconst_1
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 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 sources Lorg/reactivestreams/Publisher<+Lio/reactivex/MaybeSource<+TT;>;>;
0 3 1 maxConcurrency I
Signature: <T:Ljava/lang/Object;>(Lorg/reactivestreams/Publisher<+Lio/reactivex/MaybeSource<+TT;>;>;I)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
maxConcurrency
public static <T> io.reactivex.Flowable<T> mergeDelayError(io.reactivex.MaybeSource<? extends T>, io.reactivex.MaybeSource<? extends T>);
descriptor: (Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)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.MaybeSource
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
invokestatic io.reactivex.Maybe.mergeArrayDelayError:([Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 source1 Lio/reactivex/MaybeSource<+TT;>;
0 3 1 source2 Lio/reactivex/MaybeSource<+TT;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/MaybeSource<+TT;>;Lio/reactivex/MaybeSource<+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
source1
source2
public static <T> io.reactivex.Flowable<T> mergeDelayError(io.reactivex.MaybeSource<? extends T>, io.reactivex.MaybeSource<? extends T>, io.reactivex.MaybeSource<? extends T>);
descriptor: (Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)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.MaybeSource
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
dup
iconst_2
aload 2
aastore
invokestatic io.reactivex.Maybe.mergeArrayDelayError:([Lio/reactivex/MaybeSource;)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/MaybeSource<+TT;>;
0 4 1 source2 Lio/reactivex/MaybeSource<+TT;>;
0 4 2 source3 Lio/reactivex/MaybeSource<+TT;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/MaybeSource<+TT;>;Lio/reactivex/MaybeSource<+TT;>;Lio/reactivex/MaybeSource<+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
source1
source2
source3
public static <T> io.reactivex.Flowable<T> mergeDelayError(io.reactivex.MaybeSource<? extends T>, io.reactivex.MaybeSource<? extends T>, io.reactivex.MaybeSource<? extends T>, io.reactivex.MaybeSource<? extends T>);
descriptor: (Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)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.MaybeSource
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.Maybe.mergeArrayDelayError:([Lio/reactivex/MaybeSource;)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/MaybeSource<+TT;>;
0 5 1 source2 Lio/reactivex/MaybeSource<+TT;>;
0 5 2 source3 Lio/reactivex/MaybeSource<+TT;>;
0 5 3 source4 Lio/reactivex/MaybeSource<+TT;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/MaybeSource<+TT;>;Lio/reactivex/MaybeSource<+TT;>;Lio/reactivex/MaybeSource<+TT;>;Lio/reactivex/MaybeSource<+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
source1
source2
source3
source4
public static <T> io.reactivex.Maybe<T> never();
descriptor: ()Lio/reactivex/Maybe;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: getstatic io.reactivex.internal.operators.maybe.MaybeNever.INSTANCE:Lio/reactivex/internal/operators/maybe/MaybeNever;
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
areturn
LocalVariableTable:
Start End Slot Name Signature
Signature: <T:Ljava/lang/Object;>()Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
public static <T> io.reactivex.Single<java.lang.Boolean> sequenceEqual(io.reactivex.MaybeSource<? extends T>, io.reactivex.MaybeSource<? extends T>);
descriptor: (Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)Lio/reactivex/Single;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
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;
invokestatic io.reactivex.Maybe.sequenceEqual:(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/functions/BiPredicate;)Lio/reactivex/Single;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 source1 Lio/reactivex/MaybeSource<+TT;>;
0 1 1 source2 Lio/reactivex/MaybeSource<+TT;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/MaybeSource<+TT;>;Lio/reactivex/MaybeSource<+TT;>;)Lio/reactivex/Single<Ljava/lang/Boolean;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
source1
source2
public static <T> io.reactivex.Single<java.lang.Boolean> sequenceEqual(io.reactivex.MaybeSource<? extends T>, io.reactivex.MaybeSource<? extends T>, io.reactivex.functions.BiPredicate<? super T, ? super T>);
descriptor: (Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/functions/BiPredicate;)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
ldc "isEqual 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.maybe.MaybeEqualSingle
dup
aload 0
aload 1
aload 2
invokespecial io.reactivex.internal.operators.maybe.MaybeEqualSingle.<init>:(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;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 4 0 source1 Lio/reactivex/MaybeSource<+TT;>;
0 4 1 source2 Lio/reactivex/MaybeSource<+TT;>;
0 4 2 isEqual Lio/reactivex/functions/BiPredicate<-TT;-TT;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/MaybeSource<+TT;>;Lio/reactivex/MaybeSource<+TT;>;Lio/reactivex/functions/BiPredicate<-TT;-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
source1
source2
isEqual
public static io.reactivex.Maybe<java.lang.Long> timer(long, java.util.concurrent.TimeUnit);
descriptor: (JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Maybe;
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.Maybe.timer:(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Maybe;
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/Maybe<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.Maybe<java.lang.Long> timer(long, java.util.concurrent.TimeUnit, io.reactivex.Scheduler);
descriptor: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Maybe;
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.maybe.MaybeTimer
dup
lconst_0
lload 0
invokestatic java.lang.Math.max:(JJ)J
aload 2
aload 3
invokespecial io.reactivex.internal.operators.maybe.MaybeTimer.<init>:(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
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/Maybe<Ljava/lang/Long;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "custom")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
delay
unit
scheduler
public static <T> io.reactivex.Maybe<T> unsafeCreate(io.reactivex.MaybeSource<T>);
descriptor: (Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
instanceof io.reactivex.Maybe
ifeq 2
1: new java.lang.IllegalArgumentException
dup
ldc "unsafeCreate(Maybe) should be upgraded"
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
aload 0
ldc "onSubscribe 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.maybe.MaybeUnsafeCreate
dup
aload 0
invokespecial io.reactivex.internal.operators.maybe.MaybeUnsafeCreate.<init>:(Lio/reactivex/MaybeSource;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 onSubscribe Lio/reactivex/MaybeSource<TT;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/MaybeSource<TT;>;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
onSubscribe
public static <T, D> io.reactivex.Maybe<T> using(java.util.concurrent.Callable<? extends D>, io.reactivex.functions.Function<? super D, ? extends io.reactivex.MaybeSource<? extends T>>, io.reactivex.functions.Consumer<? super D>);
descriptor: (Ljava/util/concurrent/Callable;Lio/reactivex/functions/Function;Lio/reactivex/functions/Consumer;)Lio/reactivex/Maybe;
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.Maybe.using:(Ljava/util/concurrent/Callable;Lio/reactivex/functions/Function;Lio/reactivex/functions/Consumer;Z)Lio/reactivex/Maybe;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 resourceSupplier Ljava/util/concurrent/Callable<+TD;>;
0 1 1 sourceSupplier Lio/reactivex/functions/Function<-TD;+Lio/reactivex/MaybeSource<+TT;>;>;
0 1 2 resourceDisposer Lio/reactivex/functions/Consumer<-TD;>;
Signature: <T:Ljava/lang/Object;D:Ljava/lang/Object;>(Ljava/util/concurrent/Callable<+TD;>;Lio/reactivex/functions/Function<-TD;+Lio/reactivex/MaybeSource<+TT;>;>;Lio/reactivex/functions/Consumer<-TD;>;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
resourceSupplier
sourceSupplier
resourceDisposer
public static <T, D> io.reactivex.Maybe<T> using(java.util.concurrent.Callable<? extends D>, io.reactivex.functions.Function<? super D, ? extends io.reactivex.MaybeSource<? extends T>>, io.reactivex.functions.Consumer<? super D>, boolean);
descriptor: (Ljava/util/concurrent/Callable;Lio/reactivex/functions/Function;Lio/reactivex/functions/Consumer;Z)Lio/reactivex/Maybe;
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 "sourceSupplier 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.maybe.MaybeUsing
dup
aload 0
aload 1
aload 2
iload 3
invokespecial io.reactivex.internal.operators.maybe.MaybeUsing.<init>:(Ljava/util/concurrent/Callable;Lio/reactivex/functions/Function;Lio/reactivex/functions/Consumer;Z)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
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<+TD;>;
0 4 1 sourceSupplier Lio/reactivex/functions/Function<-TD;+Lio/reactivex/MaybeSource<+TT;>;>;
0 4 2 resourceDisposer Lio/reactivex/functions/Consumer<-TD;>;
0 4 3 eager Z
Signature: <T:Ljava/lang/Object;D:Ljava/lang/Object;>(Ljava/util/concurrent/Callable<+TD;>;Lio/reactivex/functions/Function<-TD;+Lio/reactivex/MaybeSource<+TT;>;>;Lio/reactivex/functions/Consumer<-TD;>;Z)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
resourceSupplier
sourceSupplier
resourceDisposer
eager
public static <T> io.reactivex.Maybe<T> wrap(io.reactivex.MaybeSource<T>);
descriptor: (Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
instanceof io.reactivex.Maybe
ifeq 2
1: aload 0
checkcast io.reactivex.Maybe
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
areturn
2: StackMap locals:
StackMap stack:
aload 0
ldc "onSubscribe 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.maybe.MaybeUnsafeCreate
dup
aload 0
invokespecial io.reactivex.internal.operators.maybe.MaybeUnsafeCreate.<init>:(Lio/reactivex/MaybeSource;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 source Lio/reactivex/MaybeSource<TT;>;
Signature: <T:Ljava/lang/Object;>(Lio/reactivex/MaybeSource<TT;>;)Lio/reactivex/Maybe<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.Maybe<R> zip(java.lang.Iterable<? extends io.reactivex.MaybeSource<? extends T>>, io.reactivex.functions.Function<? super java.lang.Object[], ? extends R>);
descriptor: (Ljava/lang/Iterable;Lio/reactivex/functions/Function;)Lio/reactivex/Maybe;
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.maybe.MaybeZipIterable
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.maybe.MaybeZipIterable.<init>:(Ljava/lang/Iterable;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 3 0 sources Ljava/lang/Iterable<+Lio/reactivex/MaybeSource<+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/MaybeSource<+TT;>;>;Lio/reactivex/functions/Function<-[Ljava/lang/Object;+TR;>;)Lio/reactivex/Maybe<TR;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
sources
zipper
public static <T1, T2, R> io.reactivex.Maybe<R> zip(io.reactivex.MaybeSource<? extends T1>, io.reactivex.MaybeSource<? extends T2>, io.reactivex.functions.BiFunction<? super T1, ? super T2, ? extends R>);
descriptor: (Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/functions/BiFunction;)Lio/reactivex/Maybe;
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.MaybeSource
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
invokestatic io.reactivex.Maybe.zipArray:(Lio/reactivex/functions/Function;[Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 source1 Lio/reactivex/MaybeSource<+TT1;>;
0 3 1 source2 Lio/reactivex/MaybeSource<+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/MaybeSource<+TT1;>;Lio/reactivex/MaybeSource<+TT2;>;Lio/reactivex/functions/BiFunction<-TT1;-TT2;+TR;>;)Lio/reactivex/Maybe<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.Maybe<R> zip(io.reactivex.MaybeSource<? extends T1>, io.reactivex.MaybeSource<? extends T2>, io.reactivex.MaybeSource<? extends T3>, io.reactivex.functions.Function3<? super T1, ? super T2, ? super T3, ? extends R>);
descriptor: (Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/functions/Function3;)Lio/reactivex/Maybe;
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.MaybeSource
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
dup
iconst_2
aload 2
aastore
invokestatic io.reactivex.Maybe.zipArray:(Lio/reactivex/functions/Function;[Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe;
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/MaybeSource<+TT1;>;
0 4 1 source2 Lio/reactivex/MaybeSource<+TT2;>;
0 4 2 source3 Lio/reactivex/MaybeSource<+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/MaybeSource<+TT1;>;Lio/reactivex/MaybeSource<+TT2;>;Lio/reactivex/MaybeSource<+TT3;>;Lio/reactivex/functions/Function3<-TT1;-TT2;-TT3;+TR;>;)Lio/reactivex/Maybe<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.Maybe<R> zip(io.reactivex.MaybeSource<? extends T1>, io.reactivex.MaybeSource<? extends T2>, io.reactivex.MaybeSource<? extends T3>, io.reactivex.MaybeSource<? extends T4>, io.reactivex.functions.Function4<? super T1, ? super T2, ? super T3, ? super T4, ? extends R>);
descriptor: (Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/functions/Function4;)Lio/reactivex/Maybe;
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.MaybeSource
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.Maybe.zipArray:(Lio/reactivex/functions/Function;[Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe;
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/MaybeSource<+TT1;>;
0 5 1 source2 Lio/reactivex/MaybeSource<+TT2;>;
0 5 2 source3 Lio/reactivex/MaybeSource<+TT3;>;
0 5 3 source4 Lio/reactivex/MaybeSource<+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/MaybeSource<+TT1;>;Lio/reactivex/MaybeSource<+TT2;>;Lio/reactivex/MaybeSource<+TT3;>;Lio/reactivex/MaybeSource<+TT4;>;Lio/reactivex/functions/Function4<-TT1;-TT2;-TT3;-TT4;+TR;>;)Lio/reactivex/Maybe<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.Maybe<R> zip(io.reactivex.MaybeSource<? extends T1>, io.reactivex.MaybeSource<? extends T2>, io.reactivex.MaybeSource<? extends T3>, io.reactivex.MaybeSource<? extends T4>, io.reactivex.MaybeSource<? extends T5>, io.reactivex.functions.Function5<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R>);
descriptor: (Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/functions/Function5;)Lio/reactivex/Maybe;
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.MaybeSource
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.Maybe.zipArray:(Lio/reactivex/functions/Function;[Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe;
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/MaybeSource<+TT1;>;
0 6 1 source2 Lio/reactivex/MaybeSource<+TT2;>;
0 6 2 source3 Lio/reactivex/MaybeSource<+TT3;>;
0 6 3 source4 Lio/reactivex/MaybeSource<+TT4;>;
0 6 4 source5 Lio/reactivex/MaybeSource<+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/MaybeSource<+TT1;>;Lio/reactivex/MaybeSource<+TT2;>;Lio/reactivex/MaybeSource<+TT3;>;Lio/reactivex/MaybeSource<+TT4;>;Lio/reactivex/MaybeSource<+TT5;>;Lio/reactivex/functions/Function5<-TT1;-TT2;-TT3;-TT4;-TT5;+TR;>;)Lio/reactivex/Maybe<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.Maybe<R> zip(io.reactivex.MaybeSource<? extends T1>, io.reactivex.MaybeSource<? extends T2>, io.reactivex.MaybeSource<? extends T3>, io.reactivex.MaybeSource<? extends T4>, io.reactivex.MaybeSource<? extends T5>, io.reactivex.MaybeSource<? extends T6>, io.reactivex.functions.Function6<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R>);
descriptor: (Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/functions/Function6;)Lio/reactivex/Maybe;
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.MaybeSource
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.Maybe.zipArray:(Lio/reactivex/functions/Function;[Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe;
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/MaybeSource<+TT1;>;
0 7 1 source2 Lio/reactivex/MaybeSource<+TT2;>;
0 7 2 source3 Lio/reactivex/MaybeSource<+TT3;>;
0 7 3 source4 Lio/reactivex/MaybeSource<+TT4;>;
0 7 4 source5 Lio/reactivex/MaybeSource<+TT5;>;
0 7 5 source6 Lio/reactivex/MaybeSource<+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/MaybeSource<+TT1;>;Lio/reactivex/MaybeSource<+TT2;>;Lio/reactivex/MaybeSource<+TT3;>;Lio/reactivex/MaybeSource<+TT4;>;Lio/reactivex/MaybeSource<+TT5;>;Lio/reactivex/MaybeSource<+TT6;>;Lio/reactivex/functions/Function6<-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;+TR;>;)Lio/reactivex/Maybe<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.Maybe<R> zip(io.reactivex.MaybeSource<? extends T1>, io.reactivex.MaybeSource<? extends T2>, io.reactivex.MaybeSource<? extends T3>, io.reactivex.MaybeSource<? extends T4>, io.reactivex.MaybeSource<? extends T5>, io.reactivex.MaybeSource<? extends T6>, io.reactivex.MaybeSource<? 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/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/functions/Function7;)Lio/reactivex/Maybe;
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.MaybeSource
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.Maybe.zipArray:(Lio/reactivex/functions/Function;[Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe;
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/MaybeSource<+TT1;>;
0 8 1 source2 Lio/reactivex/MaybeSource<+TT2;>;
0 8 2 source3 Lio/reactivex/MaybeSource<+TT3;>;
0 8 3 source4 Lio/reactivex/MaybeSource<+TT4;>;
0 8 4 source5 Lio/reactivex/MaybeSource<+TT5;>;
0 8 5 source6 Lio/reactivex/MaybeSource<+TT6;>;
0 8 6 source7 Lio/reactivex/MaybeSource<+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/MaybeSource<+TT1;>;Lio/reactivex/MaybeSource<+TT2;>;Lio/reactivex/MaybeSource<+TT3;>;Lio/reactivex/MaybeSource<+TT4;>;Lio/reactivex/MaybeSource<+TT5;>;Lio/reactivex/MaybeSource<+TT6;>;Lio/reactivex/MaybeSource<+TT7;>;Lio/reactivex/functions/Function7<-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;-TT7;+TR;>;)Lio/reactivex/Maybe<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.Maybe<R> zip(io.reactivex.MaybeSource<? extends T1>, io.reactivex.MaybeSource<? extends T2>, io.reactivex.MaybeSource<? extends T3>, io.reactivex.MaybeSource<? extends T4>, io.reactivex.MaybeSource<? extends T5>, io.reactivex.MaybeSource<? extends T6>, io.reactivex.MaybeSource<? extends T7>, io.reactivex.MaybeSource<? 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/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/functions/Function8;)Lio/reactivex/Maybe;
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.MaybeSource
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.Maybe.zipArray:(Lio/reactivex/functions/Function;[Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe;
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/MaybeSource<+TT1;>;
0 9 1 source2 Lio/reactivex/MaybeSource<+TT2;>;
0 9 2 source3 Lio/reactivex/MaybeSource<+TT3;>;
0 9 3 source4 Lio/reactivex/MaybeSource<+TT4;>;
0 9 4 source5 Lio/reactivex/MaybeSource<+TT5;>;
0 9 5 source6 Lio/reactivex/MaybeSource<+TT6;>;
0 9 6 source7 Lio/reactivex/MaybeSource<+TT7;>;
0 9 7 source8 Lio/reactivex/MaybeSource<+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/MaybeSource<+TT1;>;Lio/reactivex/MaybeSource<+TT2;>;Lio/reactivex/MaybeSource<+TT3;>;Lio/reactivex/MaybeSource<+TT4;>;Lio/reactivex/MaybeSource<+TT5;>;Lio/reactivex/MaybeSource<+TT6;>;Lio/reactivex/MaybeSource<+TT7;>;Lio/reactivex/MaybeSource<+TT8;>;Lio/reactivex/functions/Function8<-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;-TT7;-TT8;+TR;>;)Lio/reactivex/Maybe<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.Maybe<R> zip(io.reactivex.MaybeSource<? extends T1>, io.reactivex.MaybeSource<? extends T2>, io.reactivex.MaybeSource<? extends T3>, io.reactivex.MaybeSource<? extends T4>, io.reactivex.MaybeSource<? extends T5>, io.reactivex.MaybeSource<? extends T6>, io.reactivex.MaybeSource<? extends T7>, io.reactivex.MaybeSource<? extends T8>, io.reactivex.MaybeSource<? 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/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/functions/Function9;)Lio/reactivex/Maybe;
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.MaybeSource
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.Maybe.zipArray:(Lio/reactivex/functions/Function;[Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe;
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/MaybeSource<+TT1;>;
0 10 1 source2 Lio/reactivex/MaybeSource<+TT2;>;
0 10 2 source3 Lio/reactivex/MaybeSource<+TT3;>;
0 10 3 source4 Lio/reactivex/MaybeSource<+TT4;>;
0 10 4 source5 Lio/reactivex/MaybeSource<+TT5;>;
0 10 5 source6 Lio/reactivex/MaybeSource<+TT6;>;
0 10 6 source7 Lio/reactivex/MaybeSource<+TT7;>;
0 10 7 source8 Lio/reactivex/MaybeSource<+TT8;>;
0 10 8 source9 Lio/reactivex/MaybeSource<+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/MaybeSource<+TT1;>;Lio/reactivex/MaybeSource<+TT2;>;Lio/reactivex/MaybeSource<+TT3;>;Lio/reactivex/MaybeSource<+TT4;>;Lio/reactivex/MaybeSource<+TT5;>;Lio/reactivex/MaybeSource<+TT6;>;Lio/reactivex/MaybeSource<+TT7;>;Lio/reactivex/MaybeSource<+TT8;>;Lio/reactivex/MaybeSource<+TT9;>;Lio/reactivex/functions/Function9<-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;-TT7;-TT8;-TT9;+TR;>;)Lio/reactivex/Maybe<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.Maybe<R> zipArray(io.reactivex.functions.Function<? super java.lang.Object[], ? extends R>, io.reactivex.MaybeSource<? extends T>[]);
descriptor: (Lio/reactivex/functions/Function;[Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe;
flags: (0x0089) ACC_PUBLIC, ACC_STATIC, ACC_VARARGS
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "sources is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 1
arraylength
ifne 3
2: invokestatic io.reactivex.Maybe.empty:()Lio/reactivex/Maybe;
areturn
3: StackMap locals:
StackMap stack:
aload 0
ldc "zipper is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
4: new io.reactivex.internal.operators.maybe.MaybeZipArray
dup
aload 1
aload 0
invokespecial io.reactivex.internal.operators.maybe.MaybeZipArray.<init>:([Lio/reactivex/MaybeSource;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 5 0 zipper Lio/reactivex/functions/Function<-[Ljava/lang/Object;+TR;>;
0 5 1 sources [Lio/reactivex/MaybeSource;
Signature: <T:Ljava/lang/Object;R:Ljava/lang/Object;>(Lio/reactivex/functions/Function<-[Ljava/lang/Object;+TR;>;[Lio/reactivex/MaybeSource<+TT;>;)Lio/reactivex/Maybe<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.Maybe<T> ambWith(io.reactivex.MaybeSource<? extends T>);
descriptor: (Lio/reactivex/MaybeSource;)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 "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.MaybeSource
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
invokestatic io.reactivex.Maybe.ambArray:([Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Maybe<TT;>;
0 2 1 other Lio/reactivex/MaybeSource<+TT;>;
Signature: (Lio/reactivex/MaybeSource<+TT;>;)Lio/reactivex/Maybe<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.MaybeConverter<T, ? extends R>);
descriptor: (Lio/reactivex/MaybeConverter;)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.MaybeConverter
aload 0
invokeinterface io.reactivex.MaybeConverter.apply:(Lio/reactivex/Maybe;)Ljava/lang/Object;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Maybe<TT;>;
0 1 1 converter Lio/reactivex/MaybeConverter<TT;+TR;>;
Signature: <R:Ljava/lang/Object;>(Lio/reactivex/MaybeConverter<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 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.Maybe.subscribe:(Lio/reactivex/MaybeObserver;)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/Maybe<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 T blockingGet();
descriptor: (Ljava/lang/Object;)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 "defaultValue 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.BlockingMultiObserver
dup
invokespecial io.reactivex.internal.observers.BlockingMultiObserver.<init>:()V
astore 2
start local 2 2: aload 0
aload 2
invokevirtual io.reactivex.Maybe.subscribe:(Lio/reactivex/MaybeObserver;)V
3: aload 2
aload 1
invokevirtual io.reactivex.internal.observers.BlockingMultiObserver.blockingGet:(Ljava/lang/Object;)Ljava/lang/Object;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/reactivex/Maybe<TT;>;
0 4 1 defaultValue TT;
2 4 2 observer Lio/reactivex/internal/observers/BlockingMultiObserver<TT;>;
Signature: (TT;)TT;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
defaultValue
public final io.reactivex.Maybe<T> cache();
descriptor: ()Lio/reactivex/Maybe;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=3, locals=1, args_size=1
start local 0 0: new io.reactivex.internal.operators.maybe.MaybeCache
dup
aload 0
invokespecial io.reactivex.internal.operators.maybe.MaybeCache.<init>:(Lio/reactivex/MaybeSource;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Maybe<TT;>;
Signature: ()Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
public final <U> io.reactivex.Maybe<U> cast(java.lang.Class<? extends U>);
descriptor: (Ljava/lang/Class;)Lio/reactivex/Maybe;
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.Maybe.map:(Lio/reactivex/functions/Function;)Lio/reactivex/Maybe;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Maybe<TT;>;
0 2 1 clazz Ljava/lang/Class<+TU;>;
Signature: <U:Ljava/lang/Object;>(Ljava/lang/Class<+TU;>;)Lio/reactivex/Maybe<TU;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
clazz final
public final <R> io.reactivex.Maybe<R> compose(io.reactivex.MaybeTransformer<? super T, ? extends R>);
descriptor: (Lio/reactivex/MaybeTransformer;)Lio/reactivex/Maybe;
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.MaybeTransformer
aload 0
invokeinterface io.reactivex.MaybeTransformer.apply:(Lio/reactivex/Maybe;)Lio/reactivex/MaybeSource;
invokestatic io.reactivex.Maybe.wrap:(Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Maybe<TT;>;
0 1 1 transformer Lio/reactivex/MaybeTransformer<-TT;+TR;>;
Signature: <R:Ljava/lang/Object;>(Lio/reactivex/MaybeTransformer<-TT;+TR;>;)Lio/reactivex/Maybe<TR;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
transformer
public final <R> io.reactivex.Maybe<R> concatMap(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.maybe.MaybeFlatten
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.maybe.MaybeFlatten.<init>:(Lio/reactivex/MaybeSource;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/Maybe<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
public final io.reactivex.Flowable<T> concatWith(io.reactivex.MaybeSource<? extends T>);
descriptor: (Lio/reactivex/MaybeSource;)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 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
aload 1
invokestatic io.reactivex.Maybe.concat:(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Maybe<TT;>;
0 2 1 other Lio/reactivex/MaybeSource<+TT;>;
Signature: (Lio/reactivex/MaybeSource<+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
other
public final io.reactivex.Single<java.lang.Boolean> contains();
descriptor: (Ljava/lang/Object;)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 "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.maybe.MaybeContains
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.maybe.MaybeContains.<init>:(Lio/reactivex/MaybeSource;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/Maybe<TT;>;
0 2 1 item Ljava/lang/Object;
Signature: (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
item final
public final io.reactivex.Single<java.lang.Long> count();
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.maybe.MaybeCount
dup
aload 0
invokespecial io.reactivex.internal.operators.maybe.MaybeCount.<init>:(Lio/reactivex/MaybeSource;)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/Maybe<TT;>;
Signature: ()Lio/reactivex/Single<Ljava/lang/Long;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
public final io.reactivex.Maybe<T> defaultIfEmpty(T);
descriptor: (Ljava/lang/Object;)Lio/reactivex/Maybe;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "defaultItem 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.Maybe.just:(Ljava/lang/Object;)Lio/reactivex/Maybe;
invokevirtual io.reactivex.Maybe.switchIfEmpty:(Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Maybe<TT;>;
0 2 1 defaultItem TT;
Signature: (TT;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
defaultItem
public final io.reactivex.Maybe<T> delay(long, java.util.concurrent.TimeUnit);
descriptor: (JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Maybe;
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.Maybe.delay:(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Maybe;
areturn
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Maybe<TT;>;
0 1 1 delay J
0 1 3 unit Ljava/util/concurrent/TimeUnit;
Signature: (JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "io.reactivex:computation")
MethodParameters:
Name Flags
delay
unit
public final io.reactivex.Maybe<T> delay(long, java.util.concurrent.TimeUnit, io.reactivex.Scheduler);
descriptor: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Maybe;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=7, locals=5, args_size=4
start local 0 start local 1 start local 3 start local 4 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.maybe.MaybeDelay
dup
aload 0
lconst_0
lload 1
invokestatic java.lang.Math.max:(JJ)J
aload 3
aload 4
invokespecial io.reactivex.internal.operators.maybe.MaybeDelay.<init>:(Lio/reactivex/MaybeSource;JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
areturn
end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactivex/Maybe<TT;>;
0 3 1 delay J
0 3 3 unit Ljava/util/concurrent/TimeUnit;
0 3 4 scheduler Lio/reactivex/Scheduler;
Signature: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "custom")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
delay
unit
scheduler
public final <U, V> io.reactivex.Maybe<T> delay(org.reactivestreams.Publisher<U>);
descriptor: (Lorg/reactivestreams/Publisher;)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 "delayIndicator 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.MaybeDelayOtherPublisher
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.maybe.MaybeDelayOtherPublisher.<init>:(Lio/reactivex/MaybeSource;Lorg/reactivestreams/Publisher;)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/Maybe<TT;>;
0 2 1 delayIndicator Lorg/reactivestreams/Publisher<TU;>;
Signature: <U:Ljava/lang/Object;V:Ljava/lang/Object;>(Lorg/reactivestreams/Publisher<TU;>;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
io.reactivex.annotations.BackpressureSupport(value = io.reactivex.annotations.BackpressureKind.UNBOUNDED_IN:Lio/reactivex/annotations/BackpressureKind;)
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
delayIndicator
public final <U> io.reactivex.Maybe<T> delaySubscription(org.reactivestreams.Publisher<U>);
descriptor: (Lorg/reactivestreams/Publisher;)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 "subscriptionIndicator 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.MaybeDelaySubscriptionOtherPublisher
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.maybe.MaybeDelaySubscriptionOtherPublisher.<init>:(Lio/reactivex/MaybeSource;Lorg/reactivestreams/Publisher;)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/Maybe<TT;>;
0 2 1 subscriptionIndicator Lorg/reactivestreams/Publisher<TU;>;
Signature: <U:Ljava/lang/Object;>(Lorg/reactivestreams/Publisher<TU;>;)Lio/reactivex/Maybe<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
subscriptionIndicator
public final io.reactivex.Maybe<T> delaySubscription(long, java.util.concurrent.TimeUnit);
descriptor: (JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Maybe;
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.Maybe.delaySubscription:(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Maybe;
areturn
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Maybe<TT;>;
0 1 1 delay J
0 1 3 unit Ljava/util/concurrent/TimeUnit;
Signature: (JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "io.reactivex:computation")
MethodParameters:
Name Flags
delay
unit
public final io.reactivex.Maybe<T> delaySubscription(long, java.util.concurrent.TimeUnit, io.reactivex.Scheduler);
descriptor: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Maybe;
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.Flowable.timer:(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Flowable;
invokevirtual io.reactivex.Maybe.delaySubscription:(Lorg/reactivestreams/Publisher;)Lio/reactivex/Maybe;
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/Maybe<TT;>;
0 1 1 delay 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/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "custom")
MethodParameters:
Name Flags
delay
unit
scheduler
public final io.reactivex.Maybe<T> doAfterSuccess(io.reactivex.functions.Consumer<? super T>);
descriptor: (Lio/reactivex/functions/Consumer;)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 "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.maybe.MaybeDoAfterSuccess
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.maybe.MaybeDoAfterSuccess.<init>:(Lio/reactivex/MaybeSource;Lio/reactivex/functions/Consumer;)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/Maybe<TT;>;
0 2 1 onAfterSuccess Lio/reactivex/functions/Consumer<-TT;>;
Signature: (Lio/reactivex/functions/Consumer<-TT;>;)Lio/reactivex/Maybe<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.Maybe<T> doAfterTerminate(io.reactivex.functions.Action);
descriptor: (Lio/reactivex/functions/Action;)Lio/reactivex/Maybe;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=9, locals=2, args_size=2
start local 0 start local 1 0: new io.reactivex.internal.operators.maybe.MaybePeek
dup
aload 0
1: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
2: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
3: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
4: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
5: aload 1
ldc "onAfterTerminate is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast io.reactivex.functions.Action
6: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
7: invokespecial io.reactivex.internal.operators.maybe.MaybePeek.<init>:(Lio/reactivex/MaybeSource;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;)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 8 0 this Lio/reactivex/Maybe<TT;>;
0 8 1 onAfterTerminate Lio/reactivex/functions/Action;
Signature: (Lio/reactivex/functions/Action;)Lio/reactivex/Maybe<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.Maybe<T> doFinally(io.reactivex.functions.Action);
descriptor: (Lio/reactivex/functions/Action;)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 "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.maybe.MaybeDoFinally
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.maybe.MaybeDoFinally.<init>:(Lio/reactivex/MaybeSource;Lio/reactivex/functions/Action;)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/Maybe<TT;>;
0 2 1 onFinally Lio/reactivex/functions/Action;
Signature: (Lio/reactivex/functions/Action;)Lio/reactivex/Maybe<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.Maybe<T> doOnDispose(io.reactivex.functions.Action);
descriptor: (Lio/reactivex/functions/Action;)Lio/reactivex/Maybe;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=10, locals=2, args_size=2
start local 0 start local 1 0: new io.reactivex.internal.operators.maybe.MaybePeek
dup
aload 0
1: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
2: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
3: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
4: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
5: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
6: aload 1
ldc "onDispose is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast io.reactivex.functions.Action
7: invokespecial io.reactivex.internal.operators.maybe.MaybePeek.<init>:(Lio/reactivex/MaybeSource;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;)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 8 0 this Lio/reactivex/Maybe<TT;>;
0 8 1 onDispose Lio/reactivex/functions/Action;
Signature: (Lio/reactivex/functions/Action;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
onDispose
public final io.reactivex.Maybe<T> doOnComplete(io.reactivex.functions.Action);
descriptor: (Lio/reactivex/functions/Action;)Lio/reactivex/Maybe;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=9, locals=2, args_size=2
start local 0 start local 1 0: new io.reactivex.internal.operators.maybe.MaybePeek
dup
aload 0
1: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
2: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
3: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
4: aload 1
ldc "onComplete is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast io.reactivex.functions.Action
5: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
6: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
7: invokespecial io.reactivex.internal.operators.maybe.MaybePeek.<init>:(Lio/reactivex/MaybeSource;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;)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 8 0 this Lio/reactivex/Maybe<TT;>;
0 8 1 onComplete Lio/reactivex/functions/Action;
Signature: (Lio/reactivex/functions/Action;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
onComplete
public final io.reactivex.Maybe<T> doOnError(io.reactivex.functions.Consumer<? super java.lang.Throwable>);
descriptor: (Lio/reactivex/functions/Consumer;)Lio/reactivex/Maybe;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=9, locals=2, args_size=2
start local 0 start local 1 0: new io.reactivex.internal.operators.maybe.MaybePeek
dup
aload 0
1: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
2: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
3: aload 1
ldc "onError is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast io.reactivex.functions.Consumer
4: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
5: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
6: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
7: invokespecial io.reactivex.internal.operators.maybe.MaybePeek.<init>:(Lio/reactivex/MaybeSource;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;)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 8 0 this Lio/reactivex/Maybe<TT;>;
0 8 1 onError Lio/reactivex/functions/Consumer<-Ljava/lang/Throwable;>;
Signature: (Lio/reactivex/functions/Consumer<-Ljava/lang/Throwable;>;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
onError
public final io.reactivex.Maybe<T> doOnEvent(io.reactivex.functions.BiConsumer<? super T, ? super java.lang.Throwable>);
descriptor: (Lio/reactivex/functions/BiConsumer;)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 "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.maybe.MaybeDoOnEvent
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.maybe.MaybeDoOnEvent.<init>:(Lio/reactivex/MaybeSource;Lio/reactivex/functions/BiConsumer;)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/Maybe<TT;>;
0 2 1 onEvent Lio/reactivex/functions/BiConsumer<-TT;-Ljava/lang/Throwable;>;
Signature: (Lio/reactivex/functions/BiConsumer<-TT;-Ljava/lang/Throwable;>;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
onEvent
public final io.reactivex.Maybe<T> doOnSubscribe(io.reactivex.functions.Consumer<? super io.reactivex.disposables.Disposable>);
descriptor: (Lio/reactivex/functions/Consumer;)Lio/reactivex/Maybe;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=9, locals=2, args_size=2
start local 0 start local 1 0: new io.reactivex.internal.operators.maybe.MaybePeek
dup
aload 0
1: aload 1
ldc "onSubscribe is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast io.reactivex.functions.Consumer
2: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
3: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
4: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
5: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
6: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
7: invokespecial io.reactivex.internal.operators.maybe.MaybePeek.<init>:(Lio/reactivex/MaybeSource;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;)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 8 0 this Lio/reactivex/Maybe<TT;>;
0 8 1 onSubscribe Lio/reactivex/functions/Consumer<-Lio/reactivex/disposables/Disposable;>;
Signature: (Lio/reactivex/functions/Consumer<-Lio/reactivex/disposables/Disposable;>;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
onSubscribe
public final io.reactivex.Maybe<T> doOnTerminate(io.reactivex.functions.Action);
descriptor: (Lio/reactivex/functions/Action;)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 "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.maybe.MaybeDoOnTerminate
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.maybe.MaybeDoOnTerminate.<init>:(Lio/reactivex/MaybeSource;Lio/reactivex/functions/Action;)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/Maybe<TT;>;
0 2 1 onTerminate Lio/reactivex/functions/Action;
Signature: (Lio/reactivex/functions/Action;)Lio/reactivex/Maybe<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.Maybe<T> doOnSuccess(io.reactivex.functions.Consumer<? super T>);
descriptor: (Lio/reactivex/functions/Consumer;)Lio/reactivex/Maybe;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=9, locals=2, args_size=2
start local 0 start local 1 0: new io.reactivex.internal.operators.maybe.MaybePeek
dup
aload 0
1: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
2: aload 1
ldc "onSuccess is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast io.reactivex.functions.Consumer
3: invokestatic io.reactivex.internal.functions.Functions.emptyConsumer:()Lio/reactivex/functions/Consumer;
4: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
5: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
6: getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
7: invokespecial io.reactivex.internal.operators.maybe.MaybePeek.<init>:(Lio/reactivex/MaybeSource;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;Lio/reactivex/functions/Action;)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 8 0 this Lio/reactivex/Maybe<TT;>;
0 8 1 onSuccess Lio/reactivex/functions/Consumer<-TT;>;
Signature: (Lio/reactivex/functions/Consumer<-TT;>;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
onSuccess
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.MaybeFilter
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.maybe.MaybeFilter.<init>:(Lio/reactivex/MaybeSource;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/Maybe<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.Maybe<R> flatMap(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.maybe.MaybeFlatten
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.maybe.MaybeFlatten.<init>:(Lio/reactivex/MaybeSource;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/Maybe<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
public final <R> io.reactivex.Maybe<R> flatMap(io.reactivex.functions.Function<? super T, ? extends io.reactivex.MaybeSource<? extends R>>, io.reactivex.functions.Function<? super java.lang.Throwable, ? extends io.reactivex.MaybeSource<? extends R>>, java.util.concurrent.Callable<? extends io.reactivex.MaybeSource<? extends R>>);
descriptor: (Lio/reactivex/functions/Function;Lio/reactivex/functions/Function;Ljava/util/concurrent/Callable;)Lio/reactivex/Maybe;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=6, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
ldc "onSuccessMapper is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "onErrorMapper is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 3
ldc "onCompleteSupplier 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.maybe.MaybeFlatMapNotification
dup
aload 0
aload 1
aload 2
aload 3
invokespecial io.reactivex.internal.operators.maybe.MaybeFlatMapNotification.<init>:(Lio/reactivex/MaybeSource;Lio/reactivex/functions/Function;Lio/reactivex/functions/Function;Ljava/util/concurrent/Callable;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/reactivex/Maybe<TT;>;
0 4 1 onSuccessMapper Lio/reactivex/functions/Function<-TT;+Lio/reactivex/MaybeSource<+TR;>;>;
0 4 2 onErrorMapper Lio/reactivex/functions/Function<-Ljava/lang/Throwable;+Lio/reactivex/MaybeSource<+TR;>;>;
0 4 3 onCompleteSupplier Ljava/util/concurrent/Callable<+Lio/reactivex/MaybeSource<+TR;>;>;
Signature: <R:Ljava/lang/Object;>(Lio/reactivex/functions/Function<-TT;+Lio/reactivex/MaybeSource<+TR;>;>;Lio/reactivex/functions/Function<-Ljava/lang/Throwable;+Lio/reactivex/MaybeSource<+TR;>;>;Ljava/util/concurrent/Callable<+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
onSuccessMapper
onErrorMapper
onCompleteSupplier
public final <U, R> io.reactivex.Maybe<R> flatMap(io.reactivex.functions.Function<? super T, ? extends io.reactivex.MaybeSource<? extends U>>, io.reactivex.functions.BiFunction<? super T, ? super U, ? extends R>);
descriptor: (Lio/reactivex/functions/Function;Lio/reactivex/functions/BiFunction;)Lio/reactivex/Maybe;
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 "mapper is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "resultSelector 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.maybe.MaybeFlatMapBiSelector
dup
aload 0
aload 1
aload 2
invokespecial io.reactivex.internal.operators.maybe.MaybeFlatMapBiSelector.<init>:(Lio/reactivex/MaybeSource;Lio/reactivex/functions/Function;Lio/reactivex/functions/BiFunction;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactivex/Maybe<TT;>;
0 3 1 mapper Lio/reactivex/functions/Function<-TT;+Lio/reactivex/MaybeSource<+TU;>;>;
0 3 2 resultSelector Lio/reactivex/functions/BiFunction<-TT;-TU;+TR;>;
Signature: <U:Ljava/lang/Object;R:Ljava/lang/Object;>(Lio/reactivex/functions/Function<-TT;+Lio/reactivex/MaybeSource<+TU;>;>;Lio/reactivex/functions/BiFunction<-TT;-TU;+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
resultSelector
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.maybe.MaybeFlatMapIterableFlowable
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.maybe.MaybeFlatMapIterableFlowable.<init>:(Lio/reactivex/MaybeSource;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/Maybe<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.maybe.MaybeFlatMapIterableObservable
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.maybe.MaybeFlatMapIterableObservable.<init>:(Lio/reactivex/MaybeSource;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/Maybe<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.MaybeFlatMapObservable
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.mixed.MaybeFlatMapObservable.<init>:(Lio/reactivex/MaybeSource;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/Maybe<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 <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.mixed.MaybeFlatMapPublisher
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.mixed.MaybeFlatMapPublisher.<init>:(Lio/reactivex/MaybeSource;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/Maybe<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 <R> io.reactivex.Single<R> flatMapSingle(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.maybe.MaybeFlatMapSingle
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.maybe.MaybeFlatMapSingle.<init>:(Lio/reactivex/MaybeSource;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/Maybe<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 final
public final <R> io.reactivex.Maybe<R> flatMapSingleElement(io.reactivex.functions.Function<? super T, ? extends io.reactivex.SingleSource<? 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.maybe.MaybeFlatMapSingleElement
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.maybe.MaybeFlatMapSingleElement.<init>:(Lio/reactivex/MaybeSource;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/Maybe<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/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 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.maybe.MaybeFlatMapCompletable
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.maybe.MaybeFlatMapCompletable.<init>:(Lio/reactivex/MaybeSource;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/Maybe<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 io.reactivex.Maybe<T> hide();
descriptor: ()Lio/reactivex/Maybe;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=3, locals=1, args_size=1
start local 0 0: new io.reactivex.internal.operators.maybe.MaybeHide
dup
aload 0
invokespecial io.reactivex.internal.operators.maybe.MaybeHide.<init>:(Lio/reactivex/MaybeSource;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Maybe<TT;>;
Signature: ()Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
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.maybe.MaybeIgnoreElementCompletable
dup
aload 0
invokespecial io.reactivex.internal.operators.maybe.MaybeIgnoreElementCompletable.<init>:(Lio/reactivex/MaybeSource;)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/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
public final io.reactivex.Single<java.lang.Boolean> isEmpty();
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.maybe.MaybeIsEmptySingle
dup
aload 0
invokespecial io.reactivex.internal.operators.maybe.MaybeIsEmptySingle.<init>:(Lio/reactivex/MaybeSource;)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/Maybe<TT;>;
Signature: ()Lio/reactivex/Single<Ljava/lang/Boolean;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
public final <R> io.reactivex.Maybe<R> lift(io.reactivex.MaybeOperator<? extends R, ? super T>);
descriptor: (Lio/reactivex/MaybeOperator;)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 "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.maybe.MaybeLift
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.maybe.MaybeLift.<init>:(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeOperator;)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/Maybe<TT;>;
0 2 1 lift Lio/reactivex/MaybeOperator<+TR;-TT;>;
Signature: <R:Ljava/lang/Object;>(Lio/reactivex/MaybeOperator<+TR;-TT;>;)Lio/reactivex/Maybe<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.Maybe<R> map(io.reactivex.functions.Function<? super T, ? 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.maybe.MaybeMap
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.maybe.MaybeMap.<init>:(Lio/reactivex/MaybeSource;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/Maybe<TT;>;
0 2 1 mapper Lio/reactivex/functions/Function<-TT;+TR;>;
Signature: <R:Ljava/lang/Object;>(Lio/reactivex/functions/Function<-TT;+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
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.maybe.MaybeMaterialize
dup
aload 0
invokespecial io.reactivex.internal.operators.maybe.MaybeMaterialize.<init>:(Lio/reactivex/Maybe;)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/Maybe<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.Flowable<T> mergeWith(io.reactivex.MaybeSource<? extends T>);
descriptor: (Lio/reactivex/MaybeSource;)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 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
aload 1
invokestatic io.reactivex.Maybe.merge:(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)Lio/reactivex/Flowable;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Maybe<TT;>;
0 2 1 other Lio/reactivex/MaybeSource<+TT;>;
Signature: (Lio/reactivex/MaybeSource<+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
other
public final io.reactivex.Maybe<T> observeOn(io.reactivex.Scheduler);
descriptor: (Lio/reactivex/Scheduler;)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 "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.maybe.MaybeObserveOn
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.maybe.MaybeObserveOn.<init>:(Lio/reactivex/MaybeSource;Lio/reactivex/Scheduler;)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/Maybe<TT;>;
0 2 1 scheduler Lio/reactivex/Scheduler;
Signature: (Lio/reactivex/Scheduler;)Lio/reactivex/Maybe<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> io.reactivex.Maybe<U> ofType(java.lang.Class<U>);
descriptor: (Ljava/lang/Class;)Lio/reactivex/Maybe;
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.isInstanceOf:(Ljava/lang/Class;)Lio/reactivex/functions/Predicate;
invokevirtual io.reactivex.Maybe.filter:(Lio/reactivex/functions/Predicate;)Lio/reactivex/Maybe;
aload 1
invokevirtual io.reactivex.Maybe.cast:(Ljava/lang/Class;)Lio/reactivex/Maybe;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Maybe<TT;>;
0 2 1 clazz Ljava/lang/Class<TU;>;
Signature: <U:Ljava/lang/Object;>(Ljava/lang/Class<TU;>;)Lio/reactivex/Maybe<TU;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
clazz final
public final <R> R to(io.reactivex.functions.Function<? super io.reactivex.Maybe<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/Maybe<TT;>;
0 5 1 convert Lio/reactivex/functions/Function<-Lio/reactivex/Maybe<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/Maybe<TT;>;TR;>;)TR;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
convert
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.maybe.MaybeToFlowable
dup
aload 0
invokespecial io.reactivex.internal.operators.maybe.MaybeToFlowable.<init>:(Lio/reactivex/MaybeSource;)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/Maybe<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.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.maybe.MaybeToObservable
dup
aload 0
invokespecial io.reactivex.internal.operators.maybe.MaybeToObservable.<init>:(Lio/reactivex/MaybeSource;)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/Maybe<TT;>;
Signature: ()Lio/reactivex/Observable<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
public final io.reactivex.Single<T> toSingle(T);
descriptor: (Ljava/lang/Object;)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 "defaultValue 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.MaybeToSingle
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.maybe.MaybeToSingle.<init>:(Lio/reactivex/MaybeSource;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/Maybe<TT;>;
0 2 1 defaultValue 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
defaultValue
public final io.reactivex.Single<T> toSingle();
descriptor: ()Lio/reactivex/Single;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=1, args_size=1
start local 0 0: new io.reactivex.internal.operators.maybe.MaybeToSingle
dup
aload 0
aconst_null
invokespecial io.reactivex.internal.operators.maybe.MaybeToSingle.<init>:(Lio/reactivex/MaybeSource;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 this Lio/reactivex/Maybe<TT;>;
Signature: ()Lio/reactivex/Single<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
public final io.reactivex.Maybe<T> onErrorComplete();
descriptor: ()Lio/reactivex/Maybe;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
invokestatic io.reactivex.internal.functions.Functions.alwaysTrue:()Lio/reactivex/functions/Predicate;
invokevirtual io.reactivex.Maybe.onErrorComplete:(Lio/reactivex/functions/Predicate;)Lio/reactivex/Maybe;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Maybe<TT;>;
Signature: ()Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
public final io.reactivex.Maybe<T> onErrorComplete(io.reactivex.functions.Predicate<? super java.lang.Throwable>);
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.MaybeOnErrorComplete
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.maybe.MaybeOnErrorComplete.<init>:(Lio/reactivex/MaybeSource;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/Maybe<TT;>;
0 2 1 predicate Lio/reactivex/functions/Predicate<-Ljava/lang/Throwable;>;
Signature: (Lio/reactivex/functions/Predicate<-Ljava/lang/Throwable;>;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
predicate final
public final io.reactivex.Maybe<T> onErrorResumeNext(io.reactivex.MaybeSource<? extends T>);
descriptor: (Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "next 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.Maybe.onErrorResumeNext:(Lio/reactivex/functions/Function;)Lio/reactivex/Maybe;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Maybe<TT;>;
0 2 1 next Lio/reactivex/MaybeSource<+TT;>;
Signature: (Lio/reactivex/MaybeSource<+TT;>;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
next final
public final io.reactivex.Maybe<T> onErrorResumeNext(io.reactivex.functions.Function<? super java.lang.Throwable, ? extends io.reactivex.MaybeSource<? extends T>>);
descriptor: (Lio/reactivex/functions/Function;)Lio/reactivex/Maybe;
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.maybe.MaybeOnErrorNext
dup
aload 0
aload 1
iconst_1
invokespecial io.reactivex.internal.operators.maybe.MaybeOnErrorNext.<init>:(Lio/reactivex/MaybeSource;Lio/reactivex/functions/Function;Z)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/Maybe<TT;>;
0 2 1 resumeFunction Lio/reactivex/functions/Function<-Ljava/lang/Throwable;+Lio/reactivex/MaybeSource<+TT;>;>;
Signature: (Lio/reactivex/functions/Function<-Ljava/lang/Throwable;+Lio/reactivex/MaybeSource<+TT;>;>;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
resumeFunction
public final io.reactivex.Maybe<T> onErrorReturn(io.reactivex.functions.Function<? super java.lang.Throwable, ? extends T>);
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 "valueSupplier 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.MaybeOnErrorReturn
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.maybe.MaybeOnErrorReturn.<init>:(Lio/reactivex/MaybeSource;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/Maybe<TT;>;
0 2 1 valueSupplier Lio/reactivex/functions/Function<-Ljava/lang/Throwable;+TT;>;
Signature: (Lio/reactivex/functions/Function<-Ljava/lang/Throwable;+TT;>;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
valueSupplier
public final io.reactivex.Maybe<T> onErrorReturnItem(T);
descriptor: (Ljava/lang/Object;)Lio/reactivex/Maybe;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "item 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.Maybe.onErrorReturn:(Lio/reactivex/functions/Function;)Lio/reactivex/Maybe;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Maybe<TT;>;
0 2 1 item TT;
Signature: (TT;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
item final
public final io.reactivex.Maybe<T> onExceptionResumeNext(io.reactivex.MaybeSource<? extends T>);
descriptor: (Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "next 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.MaybeOnErrorNext
dup
aload 0
aload 1
invokestatic io.reactivex.internal.functions.Functions.justFunction:(Ljava/lang/Object;)Lio/reactivex/functions/Function;
iconst_0
invokespecial io.reactivex.internal.operators.maybe.MaybeOnErrorNext.<init>:(Lio/reactivex/MaybeSource;Lio/reactivex/functions/Function;Z)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/Maybe<TT;>;
0 2 1 next Lio/reactivex/MaybeSource<+TT;>;
Signature: (Lio/reactivex/MaybeSource<+TT;>;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
next final
public final io.reactivex.Maybe<T> onTerminateDetach();
descriptor: ()Lio/reactivex/Maybe;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=3, locals=1, args_size=1
start local 0 0: new io.reactivex.internal.operators.maybe.MaybeDetach
dup
aload 0
invokespecial io.reactivex.internal.operators.maybe.MaybeDetach.<init>:(Lio/reactivex/MaybeSource;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Maybe<TT;>;
Signature: ()Lio/reactivex/Maybe<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=3, locals=1, args_size=1
start local 0 0: aload 0
ldc 9223372036854775807
invokevirtual io.reactivex.Maybe.repeat:(J)Lio/reactivex/Flowable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Maybe<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.Maybe.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/Maybe<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> 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.Maybe.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/Maybe<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.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.Maybe.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/Maybe<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 final
public final io.reactivex.Maybe<T> retry();
descriptor: ()Lio/reactivex/Maybe;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
ldc 9223372036854775807
invokestatic io.reactivex.internal.functions.Functions.alwaysTrue:()Lio/reactivex/functions/Predicate;
invokevirtual io.reactivex.Maybe.retry:(JLio/reactivex/functions/Predicate;)Lio/reactivex/Maybe;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Maybe<TT;>;
Signature: ()Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
public final io.reactivex.Maybe<T> retry(io.reactivex.functions.BiPredicate<? super java.lang.Integer, ? super java.lang.Throwable>);
descriptor: (Lio/reactivex/functions/BiPredicate;)Lio/reactivex/Maybe;
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.Maybe.toFlowable:()Lio/reactivex/Flowable;
aload 1
invokevirtual io.reactivex.Flowable.retry:(Lio/reactivex/functions/BiPredicate;)Lio/reactivex/Flowable;
invokevirtual io.reactivex.Flowable.singleElement:()Lio/reactivex/Maybe;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Maybe<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/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
predicate
public final io.reactivex.Maybe<T> retry(long);
descriptor: (J)Lio/reactivex/Maybe;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: aload 0
lload 1
invokestatic io.reactivex.internal.functions.Functions.alwaysTrue:()Lio/reactivex/functions/Predicate;
invokevirtual io.reactivex.Maybe.retry:(JLio/reactivex/functions/Predicate;)Lio/reactivex/Maybe;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Maybe<TT;>;
0 1 1 count J
Signature: (J)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
count
public final io.reactivex.Maybe<T> retry(long, io.reactivex.functions.Predicate<? super java.lang.Throwable>);
descriptor: (JLio/reactivex/functions/Predicate;)Lio/reactivex/Maybe;
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.Maybe.toFlowable:()Lio/reactivex/Flowable;
lload 1
aload 3
invokevirtual io.reactivex.Flowable.retry:(JLio/reactivex/functions/Predicate;)Lio/reactivex/Flowable;
invokevirtual io.reactivex.Flowable.singleElement:()Lio/reactivex/Maybe;
areturn
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Maybe<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/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
times
predicate
public final io.reactivex.Maybe<T> retry(io.reactivex.functions.Predicate<? super java.lang.Throwable>);
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 0
ldc 9223372036854775807
aload 1
invokevirtual io.reactivex.Maybe.retry:(JLio/reactivex/functions/Predicate;)Lio/reactivex/Maybe;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Maybe<TT;>;
0 1 1 predicate Lio/reactivex/functions/Predicate<-Ljava/lang/Throwable;>;
Signature: (Lio/reactivex/functions/Predicate<-Ljava/lang/Throwable;>;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
predicate
public final io.reactivex.Maybe<T> retryUntil(io.reactivex.functions.BooleanSupplier);
descriptor: (Lio/reactivex/functions/BooleanSupplier;)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 "stop is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
ldc 9223372036854775807
aload 1
invokestatic io.reactivex.internal.functions.Functions.predicateReverseFor:(Lio/reactivex/functions/BooleanSupplier;)Lio/reactivex/functions/Predicate;
invokevirtual io.reactivex.Maybe.retry:(JLio/reactivex/functions/Predicate;)Lio/reactivex/Maybe;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Maybe<TT;>;
0 2 1 stop Lio/reactivex/functions/BooleanSupplier;
Signature: (Lio/reactivex/functions/BooleanSupplier;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
stop final
public final io.reactivex.Maybe<T> retryWhen(io.reactivex.functions.Function<? super io.reactivex.Flowable<java.lang.Throwable>, ? extends org.reactivestreams.Publisher<?>>);
descriptor: (Lio/reactivex/functions/Function;)Lio/reactivex/Maybe;
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.Maybe.toFlowable:()Lio/reactivex/Flowable;
aload 1
invokevirtual io.reactivex.Flowable.retryWhen:(Lio/reactivex/functions/Function;)Lio/reactivex/Flowable;
invokevirtual io.reactivex.Flowable.singleElement:()Lio/reactivex/Maybe;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Maybe<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/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
handler final
public final io.reactivex.disposables.Disposable subscribe();
descriptor: ()Lio/reactivex/disposables/Disposable;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=4, 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;
getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
invokevirtual io.reactivex.Maybe.subscribe:(Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;)Lio/reactivex/disposables/Disposable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.SchedulerSupport(value = "none")
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=4, 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;
getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
invokevirtual io.reactivex.Maybe.subscribe:(Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;)Lio/reactivex/disposables/Disposable;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Maybe<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=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
getstatic io.reactivex.internal.functions.Functions.EMPTY_ACTION:Lio/reactivex/functions/Action;
invokevirtual io.reactivex.Maybe.subscribe:(Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;)Lio/reactivex/disposables/Disposable;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Maybe<TT;>;
0 1 1 onSuccess Lio/reactivex/functions/Consumer<-TT;>;
0 1 2 onError Lio/reactivex/functions/Consumer<-Ljava/lang/Throwable;>;
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")
MethodParameters:
Name Flags
onSuccess
onError
public final io.reactivex.disposables.Disposable subscribe(io.reactivex.functions.Consumer<? super T>, io.reactivex.functions.Consumer<? super java.lang.Throwable>, io.reactivex.functions.Action);
descriptor: (Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;)Lio/reactivex/disposables/Disposable;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=6, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 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: aload 3
ldc "onComplete is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
3: aload 0
new io.reactivex.internal.operators.maybe.MaybeCallbackObserver
dup
aload 1
aload 2
aload 3
invokespecial io.reactivex.internal.operators.maybe.MaybeCallbackObserver.<init>:(Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;)V
invokevirtual io.reactivex.Maybe.subscribeWith:(Lio/reactivex/MaybeObserver;)Lio/reactivex/MaybeObserver;
checkcast io.reactivex.disposables.Disposable
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/reactivex/Maybe<TT;>;
0 4 1 onSuccess Lio/reactivex/functions/Consumer<-TT;>;
0 4 2 onError Lio/reactivex/functions/Consumer<-Ljava/lang/Throwable;>;
0 4 3 onComplete Lio/reactivex/functions/Action;
Signature: (Lio/reactivex/functions/Consumer<-TT;>;Lio/reactivex/functions/Consumer<-Ljava/lang/Throwable;>;Lio/reactivex/functions/Action;)Lio/reactivex/disposables/Disposable;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
onSuccess
onError
onComplete
public final void subscribe(io.reactivex.MaybeObserver<? super T>);
descriptor: (Lio/reactivex/MaybeObserver;)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/Maybe;Lio/reactivex/MaybeObserver;)Lio/reactivex/MaybeObserver;
astore 1
2: aload 1
ldc "The RxJavaPlugins.onSubscribe hook returned a null MaybeObserver. Please check the handler provided to RxJavaPlugins.setOnMaybeSubscribe 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.Maybe.subscribeActual:(Lio/reactivex/MaybeObserver;)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/Maybe<TT;>;
0 13 1 observer Lio/reactivex/MaybeObserver<-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/MaybeObserver<-TT;>;)V
RuntimeVisibleAnnotations:
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
observer
protected abstract void subscribeActual(io.reactivex.MaybeObserver<? super T>);
descriptor: (Lio/reactivex/MaybeObserver;)V
flags: (0x0404) ACC_PROTECTED, ACC_ABSTRACT
Signature: (Lio/reactivex/MaybeObserver<-TT;>;)V
MethodParameters:
Name Flags
observer
public final io.reactivex.Maybe<T> subscribeOn(io.reactivex.Scheduler);
descriptor: (Lio/reactivex/Scheduler;)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 "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.maybe.MaybeSubscribeOn
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.maybe.MaybeSubscribeOn.<init>:(Lio/reactivex/MaybeSource;Lio/reactivex/Scheduler;)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/Maybe<TT;>;
0 2 1 scheduler Lio/reactivex/Scheduler;
Signature: (Lio/reactivex/Scheduler;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "custom")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
scheduler
public final <E extends io.reactivex.MaybeObserver<? super T>> E subscribeWith();
descriptor: (Lio/reactivex/MaybeObserver;)Lio/reactivex/MaybeObserver;
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.Maybe.subscribe:(Lio/reactivex/MaybeObserver;)V
1: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Maybe<TT;>;
0 2 1 observer TE;
Signature: <E::Lio/reactivex/MaybeObserver<-TT;>;>(TE;)TE;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
MethodParameters:
Name Flags
observer
public final io.reactivex.Maybe<T> switchIfEmpty(io.reactivex.MaybeSource<? extends T>);
descriptor: (Lio/reactivex/MaybeSource;)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 "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.maybe.MaybeSwitchIfEmpty
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.maybe.MaybeSwitchIfEmpty.<init>:(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)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/Maybe<TT;>;
0 2 1 other Lio/reactivex/MaybeSource<+TT;>;
Signature: (Lio/reactivex/MaybeSource<+TT;>;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
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> switchIfEmpty(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: new io.reactivex.internal.operators.maybe.MaybeSwitchIfEmptySingle
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.maybe.MaybeSwitchIfEmptySingle.<init>:(Lio/reactivex/MaybeSource;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/Maybe<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 <U> io.reactivex.Maybe<T> takeUntil(io.reactivex.MaybeSource<U>);
descriptor: (Lio/reactivex/MaybeSource;)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 "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.maybe.MaybeTakeUntilMaybe
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.maybe.MaybeTakeUntilMaybe.<init>:(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)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/Maybe<TT;>;
0 2 1 other Lio/reactivex/MaybeSource<TU;>;
Signature: <U:Ljava/lang/Object;>(Lio/reactivex/MaybeSource<TU;>;)Lio/reactivex/Maybe<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.Maybe<T> takeUntil(org.reactivestreams.Publisher<U>);
descriptor: (Lorg/reactivestreams/Publisher;)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 "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.maybe.MaybeTakeUntilPublisher
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.maybe.MaybeTakeUntilPublisher.<init>:(Lio/reactivex/MaybeSource;Lorg/reactivestreams/Publisher;)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/Maybe<TT;>;
0 2 1 other Lorg/reactivestreams/Publisher<TU;>;
Signature: <U:Ljava/lang/Object;>(Lorg/reactivestreams/Publisher<TU;>;)Lio/reactivex/Maybe<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
other
public final io.reactivex.Maybe<T> timeout(long, java.util.concurrent.TimeUnit);
descriptor: (JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Maybe;
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.Maybe.timeout:(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Maybe;
areturn
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/Maybe<TT;>;
0 1 1 timeout J
0 1 3 timeUnit Ljava/util/concurrent/TimeUnit;
Signature: (JLjava/util/concurrent/TimeUnit;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "io.reactivex:computation")
MethodParameters:
Name Flags
timeout
timeUnit
public final io.reactivex.Maybe<T> timeout(long, java.util.concurrent.TimeUnit, io.reactivex.MaybeSource<? extends T>);
descriptor: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe;
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 "fallback 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.Maybe.timeout:(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe;
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/Maybe<TT;>;
0 2 1 timeout J
0 2 3 timeUnit Ljava/util/concurrent/TimeUnit;
0 2 4 fallback Lio/reactivex/MaybeSource<+TT;>;
Signature: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/MaybeSource<+TT;>;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "io.reactivex:computation")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
timeout
timeUnit
fallback
public final io.reactivex.Maybe<T> timeout(long, java.util.concurrent.TimeUnit, io.reactivex.Scheduler, io.reactivex.MaybeSource<? extends T>);
descriptor: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=5, locals=6, args_size=5
start local 0 start local 1 start local 3 start local 4 start local 5 0: aload 5
ldc "fallback 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
invokestatic io.reactivex.Maybe.timer:(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Maybe;
aload 5
invokevirtual io.reactivex.Maybe.timeout:(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe;
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/Maybe<TT;>;
0 2 1 timeout J
0 2 3 timeUnit Ljava/util/concurrent/TimeUnit;
0 2 4 scheduler Lio/reactivex/Scheduler;
0 2 5 fallback Lio/reactivex/MaybeSource<+TT;>;
Signature: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;Lio/reactivex/MaybeSource<+TT;>;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "custom")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
timeout
timeUnit
scheduler
fallback
public final io.reactivex.Maybe<T> timeout(long, java.util.concurrent.TimeUnit, io.reactivex.Scheduler);
descriptor: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Maybe;
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.Maybe.timer:(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Maybe;
invokevirtual io.reactivex.Maybe.timeout:(Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe;
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/Maybe<TT;>;
0 1 1 timeout J
0 1 3 timeUnit Ljava/util/concurrent/TimeUnit;
0 1 4 scheduler Lio/reactivex/Scheduler;
Signature: (JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "custom")
MethodParameters:
Name Flags
timeout
timeUnit
scheduler
public final <U> io.reactivex.Maybe<T> timeout(io.reactivex.MaybeSource<U>);
descriptor: (Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "timeoutIndicator 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.MaybeTimeoutMaybe
dup
aload 0
aload 1
aconst_null
invokespecial io.reactivex.internal.operators.maybe.MaybeTimeoutMaybe.<init>:(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)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/Maybe<TT;>;
0 2 1 timeoutIndicator Lio/reactivex/MaybeSource<TU;>;
Signature: <U:Ljava/lang/Object;>(Lio/reactivex/MaybeSource<TU;>;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
timeoutIndicator
public final <U> io.reactivex.Maybe<T> timeout(io.reactivex.MaybeSource<U>, io.reactivex.MaybeSource<? extends T>);
descriptor: (Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe;
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 "timeoutIndicator is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "fallback 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.maybe.MaybeTimeoutMaybe
dup
aload 0
aload 1
aload 2
invokespecial io.reactivex.internal.operators.maybe.MaybeTimeoutMaybe.<init>:(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactivex/Maybe<TT;>;
0 3 1 timeoutIndicator Lio/reactivex/MaybeSource<TU;>;
0 3 2 fallback Lio/reactivex/MaybeSource<+TT;>;
Signature: <U:Ljava/lang/Object;>(Lio/reactivex/MaybeSource<TU;>;Lio/reactivex/MaybeSource<+TT;>;)Lio/reactivex/Maybe<TT;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
timeoutIndicator
fallback
public final <U> io.reactivex.Maybe<T> timeout(org.reactivestreams.Publisher<U>);
descriptor: (Lorg/reactivestreams/Publisher;)Lio/reactivex/Maybe;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "timeoutIndicator 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.MaybeTimeoutPublisher
dup
aload 0
aload 1
aconst_null
invokespecial io.reactivex.internal.operators.maybe.MaybeTimeoutPublisher.<init>:(Lio/reactivex/MaybeSource;Lorg/reactivestreams/Publisher;Lio/reactivex/MaybeSource;)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/Maybe<TT;>;
0 2 1 timeoutIndicator Lorg/reactivestreams/Publisher<TU;>;
Signature: <U:Ljava/lang/Object;>(Lorg/reactivestreams/Publisher<TU;>;)Lio/reactivex/Maybe<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
timeoutIndicator
public final <U> io.reactivex.Maybe<T> timeout(org.reactivestreams.Publisher<U>, io.reactivex.MaybeSource<? extends T>);
descriptor: (Lorg/reactivestreams/Publisher;Lio/reactivex/MaybeSource;)Lio/reactivex/Maybe;
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 "timeoutIndicator is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "fallback 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.maybe.MaybeTimeoutPublisher
dup
aload 0
aload 1
aload 2
invokespecial io.reactivex.internal.operators.maybe.MaybeTimeoutPublisher.<init>:(Lio/reactivex/MaybeSource;Lorg/reactivestreams/Publisher;Lio/reactivex/MaybeSource;)V
invokestatic io.reactivex.plugins.RxJavaPlugins.onAssembly:(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactivex/Maybe<TT;>;
0 3 1 timeoutIndicator Lorg/reactivestreams/Publisher<TU;>;
0 3 2 fallback Lio/reactivex/MaybeSource<+TT;>;
Signature: <U:Ljava/lang/Object;>(Lorg/reactivestreams/Publisher<TU;>;Lio/reactivex/MaybeSource<+TT;>;)Lio/reactivex/Maybe<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
timeoutIndicator
fallback
public final io.reactivex.Maybe<T> unsubscribeOn(io.reactivex.Scheduler);
descriptor: (Lio/reactivex/Scheduler;)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 "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.maybe.MaybeUnsubscribeOn
dup
aload 0
aload 1
invokespecial io.reactivex.internal.operators.maybe.MaybeUnsubscribeOn.<init>:(Lio/reactivex/MaybeSource;Lio/reactivex/Scheduler;)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/Maybe<TT;>;
0 2 1 scheduler Lio/reactivex/Scheduler;
Signature: (Lio/reactivex/Scheduler;)Lio/reactivex/Maybe<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.Maybe<R> zipWith(io.reactivex.MaybeSource<? extends U>, io.reactivex.functions.BiFunction<? super T, ? super U, ? extends R>);
descriptor: (Lio/reactivex/MaybeSource;Lio/reactivex/functions/BiFunction;)Lio/reactivex/Maybe;
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 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
aload 1
aload 2
invokestatic io.reactivex.Maybe.zip:(Lio/reactivex/MaybeSource;Lio/reactivex/MaybeSource;Lio/reactivex/functions/BiFunction;)Lio/reactivex/Maybe;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactivex/Maybe<TT;>;
0 2 1 other Lio/reactivex/MaybeSource<+TU;>;
0 2 2 zipper Lio/reactivex/functions/BiFunction<-TT;-TU;+TR;>;
Signature: <U:Ljava/lang/Object;R:Ljava/lang/Object;>(Lio/reactivex/MaybeSource<+TU;>;Lio/reactivex/functions/BiFunction<-TT;-TU;+TR;>;)Lio/reactivex/Maybe<TR;>;
RuntimeVisibleAnnotations:
io.reactivex.annotations.CheckReturnValue()
io.reactivex.annotations.SchedulerSupport(value = "none")
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
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.Maybe.subscribe:(Lio/reactivex/MaybeObserver;)V
2: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactivex/Maybe<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.Maybe.subscribe:(Lio/reactivex/MaybeObserver;)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/Maybe<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
}
Signature: <T:Ljava/lang/Object;>Ljava/lang/Object;Lio/reactivex/MaybeSource<TT;>;
SourceFile: "Maybe.java"
