https://github.com/ReactiveX/RxJava: Reactive Extensions for Java
  • David Karnok 
final class io.reactivex.internal.operators.mixed.ScalarXMapZHelper
  minor version: 0
  major version: 59
  flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
  this_class: io.reactivex.internal.operators.mixed.ScalarXMapZHelper
  super_class: java.lang.Object
{
  private void <init>();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.internal.operators.mixed.ScalarXMapZHelper this
         0: .line 35
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 36
            new java.lang.IllegalStateException
            dup
            ldc "No instances!"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
        end local 0 // io.reactivex.internal.operators.mixed.ScalarXMapZHelper this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/reactivex/internal/operators/mixed/ScalarXMapZHelper;

  static <T> boolean tryAsCompletable(, io.reactivex.functions.Function<? super T, ? extends io.reactivex.CompletableSource>, io.reactivex.CompletableObserver);
    descriptor: (Ljava/lang/Object;Lio/reactivex/functions/Function;Lio/reactivex/CompletableObserver;)Z
    flags: (0x0008) ACC_STATIC
    Code:
      stack=2, locals=6, args_size=3
        start local 0 // java.lang.Object source
        start local 1 // io.reactivex.functions.Function mapper
        start local 2 // io.reactivex.CompletableObserver observer
         0: .line 53
            aload 0 /* source */
            instanceof java.util.concurrent.Callable
            ifeq 16
         1: .line 55
            aload 0 /* source */
            checkcast java.util.concurrent.Callable
            astore 3 /* call */
        start local 3 // java.util.concurrent.Callable call
         2: .line 56
            aconst_null
            astore 4 /* cs */
        start local 4 // io.reactivex.CompletableSource cs
         3: .line 58
            aload 3 /* call */
            invokeinterface java.util.concurrent.Callable.call:()Ljava/lang/Object;
            astore 5 /* item */
        start local 5 // java.lang.Object item
         4: .line 59
            aload 5 /* item */
            ifnull 11
         5: .line 60
            aload 1 /* mapper */
            aload 5 /* item */
            invokeinterface io.reactivex.functions.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.reactivex.CompletableSource
            ldc "The mapper returned a null CompletableSource"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            checkcast io.reactivex.CompletableSource
            astore 4 /* cs */
        end local 5 // java.lang.Object item
         6: .line 62
            goto 11
      StackMap locals: java.lang.Object io.reactivex.functions.Function io.reactivex.CompletableObserver java.util.concurrent.Callable io.reactivex.CompletableSource
      StackMap stack: java.lang.Throwable
         7: astore 5 /* ex */
        start local 5 // java.lang.Throwable ex
         8: .line 63
            aload 5 /* ex */
            invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
         9: .line 64
            aload 5 /* ex */
            aload 2 /* observer */
            invokestatic io.reactivex.internal.disposables.EmptyDisposable.error:(Ljava/lang/Throwable;Lio/reactivex/CompletableObserver;)V
        10: .line 65
            iconst_1
            ireturn
        end local 5 // java.lang.Throwable ex
        11: .line 68
      StackMap locals:
      StackMap stack:
            aload 4 /* cs */
            ifnonnull 14
        12: .line 69
            aload 2 /* observer */
            invokestatic io.reactivex.internal.disposables.EmptyDisposable.complete:(Lio/reactivex/CompletableObserver;)V
        13: .line 70
            goto 15
        14: .line 71
      StackMap locals:
      StackMap stack:
            aload 4 /* cs */
            aload 2 /* observer */
            invokeinterface io.reactivex.CompletableSource.subscribe:(Lio/reactivex/CompletableObserver;)V
        15: .line 73
      StackMap locals:
      StackMap stack:
            iconst_1
            ireturn
        end local 4 // io.reactivex.CompletableSource cs
        end local 3 // java.util.concurrent.Callable call
        16: .line 75
      StackMap locals:
      StackMap stack:
            iconst_0
            ireturn
        end local 2 // io.reactivex.CompletableObserver observer
        end local 1 // io.reactivex.functions.Function mapper
        end local 0 // java.lang.Object source
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   17     0    source  Ljava/lang/Object;
            0   17     1    mapper  Lio/reactivex/functions/Function<-TT;+Lio/reactivex/CompletableSource;>;
            0   17     2  observer  Lio/reactivex/CompletableObserver;
            2   16     3      call  Ljava/util/concurrent/Callable<TT;>;
            3   16     4        cs  Lio/reactivex/CompletableSource;
            4    6     5      item  TT;
            8   11     5        ex  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           3     6       7  Class java.lang.Throwable
    Signature: <T:Ljava/lang/Object;>(Ljava/lang/Object;Lio/reactivex/functions/Function<-TT;+Lio/reactivex/CompletableSource;>;Lio/reactivex/CompletableObserver;)Z
    MethodParameters:
          Name  Flags
      source    
      mapper    
      observer  

  static <T, R> boolean tryAsMaybe(, io.reactivex.functions.Function<? super T, ? extends io.reactivex.MaybeSource<? extends R>>, io.reactivex.Observer<? super R>);
    descriptor: (Ljava/lang/Object;Lio/reactivex/functions/Function;Lio/reactivex/Observer;)Z
    flags: (0x0008) ACC_STATIC
    Code:
      stack=2, locals=6, args_size=3
        start local 0 // java.lang.Object source
        start local 1 // io.reactivex.functions.Function mapper
        start local 2 // io.reactivex.Observer observer
         0: .line 92
            aload 0 /* source */
            instanceof java.util.concurrent.Callable
            ifeq 16
         1: .line 94
            aload 0 /* source */
            checkcast java.util.concurrent.Callable
            astore 3 /* call */
        start local 3 // java.util.concurrent.Callable call
         2: .line 95
            aconst_null
            astore 4 /* cs */
        start local 4 // io.reactivex.MaybeSource cs
         3: .line 97
            aload 3 /* call */
            invokeinterface java.util.concurrent.Callable.call:()Ljava/lang/Object;
            astore 5 /* item */
        start local 5 // java.lang.Object item
         4: .line 98
            aload 5 /* item */
            ifnull 11
         5: .line 99
            aload 1 /* mapper */
            aload 5 /* item */
            invokeinterface io.reactivex.functions.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.reactivex.MaybeSource
            ldc "The mapper returned a null MaybeSource"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            checkcast io.reactivex.MaybeSource
            astore 4 /* cs */
        end local 5 // java.lang.Object item
         6: .line 101
            goto 11
      StackMap locals: java.lang.Object io.reactivex.functions.Function io.reactivex.Observer java.util.concurrent.Callable io.reactivex.MaybeSource
      StackMap stack: java.lang.Throwable
         7: astore 5 /* ex */
        start local 5 // java.lang.Throwable ex
         8: .line 102
            aload 5 /* ex */
            invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
         9: .line 103
            aload 5 /* ex */
            aload 2 /* observer */
            invokestatic io.reactivex.internal.disposables.EmptyDisposable.error:(Ljava/lang/Throwable;Lio/reactivex/Observer;)V
        10: .line 104
            iconst_1
            ireturn
        end local 5 // java.lang.Throwable ex
        11: .line 107
      StackMap locals:
      StackMap stack:
            aload 4 /* cs */
            ifnonnull 14
        12: .line 108
            aload 2 /* observer */
            invokestatic io.reactivex.internal.disposables.EmptyDisposable.complete:(Lio/reactivex/Observer;)V
        13: .line 109
            goto 15
        14: .line 110
      StackMap locals:
      StackMap stack:
            aload 4 /* cs */
            aload 2 /* observer */
            invokestatic io.reactivex.internal.operators.maybe.MaybeToObservable.create:(Lio/reactivex/Observer;)Lio/reactivex/MaybeObserver;
            invokeinterface io.reactivex.MaybeSource.subscribe:(Lio/reactivex/MaybeObserver;)V
        15: .line 112
      StackMap locals:
      StackMap stack:
            iconst_1
            ireturn
        end local 4 // io.reactivex.MaybeSource cs
        end local 3 // java.util.concurrent.Callable call
        16: .line 114
      StackMap locals:
      StackMap stack:
            iconst_0
            ireturn
        end local 2 // io.reactivex.Observer observer
        end local 1 // io.reactivex.functions.Function mapper
        end local 0 // java.lang.Object source
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   17     0    source  Ljava/lang/Object;
            0   17     1    mapper  Lio/reactivex/functions/Function<-TT;+Lio/reactivex/MaybeSource<+TR;>;>;
            0   17     2  observer  Lio/reactivex/Observer<-TR;>;
            2   16     3      call  Ljava/util/concurrent/Callable<TT;>;
            3   16     4        cs  Lio/reactivex/MaybeSource<+TR;>;
            4    6     5      item  TT;
            8   11     5        ex  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           3     6       7  Class java.lang.Throwable
    Signature: <T:Ljava/lang/Object;R:Ljava/lang/Object;>(Ljava/lang/Object;Lio/reactivex/functions/Function<-TT;+Lio/reactivex/MaybeSource<+TR;>;>;Lio/reactivex/Observer<-TR;>;)Z
    MethodParameters:
          Name  Flags
      source    
      mapper    
      observer  

  static <T, R> boolean tryAsSingle(, io.reactivex.functions.Function<? super T, ? extends io.reactivex.SingleSource<? extends R>>, io.reactivex.Observer<? super R>);
    descriptor: (Ljava/lang/Object;Lio/reactivex/functions/Function;Lio/reactivex/Observer;)Z
    flags: (0x0008) ACC_STATIC
    Code:
      stack=2, locals=6, args_size=3
        start local 0 // java.lang.Object source
        start local 1 // io.reactivex.functions.Function mapper
        start local 2 // io.reactivex.Observer observer
         0: .line 131
            aload 0 /* source */
            instanceof java.util.concurrent.Callable
            ifeq 16
         1: .line 133
            aload 0 /* source */
            checkcast java.util.concurrent.Callable
            astore 3 /* call */
        start local 3 // java.util.concurrent.Callable call
         2: .line 134
            aconst_null
            astore 4 /* cs */
        start local 4 // io.reactivex.SingleSource cs
         3: .line 136
            aload 3 /* call */
            invokeinterface java.util.concurrent.Callable.call:()Ljava/lang/Object;
            astore 5 /* item */
        start local 5 // java.lang.Object item
         4: .line 137
            aload 5 /* item */
            ifnull 11
         5: .line 138
            aload 1 /* mapper */
            aload 5 /* item */
            invokeinterface io.reactivex.functions.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.reactivex.SingleSource
            ldc "The mapper returned a null SingleSource"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            checkcast io.reactivex.SingleSource
            astore 4 /* cs */
        end local 5 // java.lang.Object item
         6: .line 140
            goto 11
      StackMap locals: java.lang.Object io.reactivex.functions.Function io.reactivex.Observer java.util.concurrent.Callable io.reactivex.SingleSource
      StackMap stack: java.lang.Throwable
         7: astore 5 /* ex */
        start local 5 // java.lang.Throwable ex
         8: .line 141
            aload 5 /* ex */
            invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
         9: .line 142
            aload 5 /* ex */
            aload 2 /* observer */
            invokestatic io.reactivex.internal.disposables.EmptyDisposable.error:(Ljava/lang/Throwable;Lio/reactivex/Observer;)V
        10: .line 143
            iconst_1
            ireturn
        end local 5 // java.lang.Throwable ex
        11: .line 146
      StackMap locals:
      StackMap stack:
            aload 4 /* cs */
            ifnonnull 14
        12: .line 147
            aload 2 /* observer */
            invokestatic io.reactivex.internal.disposables.EmptyDisposable.complete:(Lio/reactivex/Observer;)V
        13: .line 148
            goto 15
        14: .line 149
      StackMap locals:
      StackMap stack:
            aload 4 /* cs */
            aload 2 /* observer */
            invokestatic io.reactivex.internal.operators.single.SingleToObservable.create:(Lio/reactivex/Observer;)Lio/reactivex/SingleObserver;
            invokeinterface io.reactivex.SingleSource.subscribe:(Lio/reactivex/SingleObserver;)V
        15: .line 151
      StackMap locals:
      StackMap stack:
            iconst_1
            ireturn
        end local 4 // io.reactivex.SingleSource cs
        end local 3 // java.util.concurrent.Callable call
        16: .line 153
      StackMap locals:
      StackMap stack:
            iconst_0
            ireturn
        end local 2 // io.reactivex.Observer observer
        end local 1 // io.reactivex.functions.Function mapper
        end local 0 // java.lang.Object source
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   17     0    source  Ljava/lang/Object;
            0   17     1    mapper  Lio/reactivex/functions/Function<-TT;+Lio/reactivex/SingleSource<+TR;>;>;
            0   17     2  observer  Lio/reactivex/Observer<-TR;>;
            2   16     3      call  Ljava/util/concurrent/Callable<TT;>;
            3   16     4        cs  Lio/reactivex/SingleSource<+TR;>;
            4    6     5      item  TT;
            8   11     5        ex  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           3     6       7  Class java.lang.Throwable
    Signature: <T:Ljava/lang/Object;R:Ljava/lang/Object;>(Ljava/lang/Object;Lio/reactivex/functions/Function<-TT;+Lio/reactivex/SingleSource<+TR;>;>;Lio/reactivex/Observer<-TR;>;)Z
    MethodParameters:
          Name  Flags
      source    
      mapper    
      observer  
}
SourceFile: "ScalarXMapZHelper.java"