https://github.com/reactor/reactor-core: Non-Blocking Reactive Foundation for the JVM (reactor)
  • Stephane Maldini
  • David Karnok
  • Simon Baslé
  • Sergei Egorov
  • Sébastien Deleuze 
final class reactor.core.publisher.FluxFlatMap<T, R> extends reactor.core.publisher.InternalFluxOperator<T, R>
  minor version: 0
  major version: 59
  flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
  this_class: reactor.core.publisher.FluxFlatMap
  super_class: reactor.core.publisher.InternalFluxOperator
{
  final java.util.function.Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper;
    descriptor: Ljava/util/function/Function;
    flags: (0x0010) ACC_FINAL
    Signature: Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;

  final boolean delayError;
    descriptor: Z
    flags: (0x0010) ACC_FINAL

  final int maxConcurrency;
    descriptor: I
    flags: (0x0010) ACC_FINAL

  final java.util.function.Supplier<? extends java.util.Queue<R>> mainQueueSupplier;
    descriptor: Ljava/util/function/Supplier;
    flags: (0x0010) ACC_FINAL
    Signature: Ljava/util/function/Supplier<+Ljava/util/Queue<TR;>;>;

  final int prefetch;
    descriptor: I
    flags: (0x0010) ACC_FINAL

  final java.util.function.Supplier<? extends java.util.Queue<R>> innerQueueSupplier;
    descriptor: Ljava/util/function/Supplier;
    flags: (0x0010) ACC_FINAL
    Signature: Ljava/util/function/Supplier<+Ljava/util/Queue<TR;>;>;

  void <init>(reactor.core.publisher.Flux<? extends T>, java.util.function.Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>>, boolean, int, java.util.function.Supplier<? extends java.util.Queue<R>>, int, java.util.function.Supplier<? extends java.util.Queue<R>>);
    descriptor: (Lreactor/core/publisher/Flux;Ljava/util/function/Function;ZILjava/util/function/Supplier;ILjava/util/function/Supplier;)V
    flags: (0x0000) 
    Code:
      stack=5, locals=8, args_size=8
        start local 0 // reactor.core.publisher.FluxFlatMap this
        start local 1 // reactor.core.publisher.Flux source
        start local 2 // java.util.function.Function mapper
        start local 3 // boolean delayError
        start local 4 // int maxConcurrency
        start local 5 // java.util.function.Supplier mainQueueSupplier
        start local 6 // int prefetch
        start local 7 // java.util.function.Supplier innerQueueSupplier
         0: .line 68
            aload 0 /* this */
            aload 1 /* source */
            invokespecial reactor.core.publisher.InternalFluxOperator.<init>:(Lreactor/core/publisher/Flux;)V
         1: .line 69
            iload 6 /* prefetch */
            ifgt 3
         2: .line 70
            new java.lang.IllegalArgumentException
            dup
            new java.lang.StringBuilder
            dup
            ldc "prefetch > 0 required but it was "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            iload 6 /* prefetch */
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
            athrow
         3: .line 72
      StackMap locals: reactor.core.publisher.FluxFlatMap reactor.core.publisher.Flux java.util.function.Function int int java.util.function.Supplier int java.util.function.Supplier
      StackMap stack:
            iload 4 /* maxConcurrency */
            ifgt 5
         4: .line 73
            new java.lang.IllegalArgumentException
            dup
            new java.lang.StringBuilder
            dup
            ldc "maxConcurrency > 0 required but it was "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            iload 4 /* maxConcurrency */
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
            athrow
         5: .line 75
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 2 /* mapper */
            ldc "mapper"
            invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            checkcast java.util.function.Function
            putfield reactor.core.publisher.FluxFlatMap.mapper:Ljava/util/function/Function;
         6: .line 76
            aload 0 /* this */
            iload 3 /* delayError */
            putfield reactor.core.publisher.FluxFlatMap.delayError:Z
         7: .line 77
            aload 0 /* this */
            iload 6 /* prefetch */
            putfield reactor.core.publisher.FluxFlatMap.prefetch:I
         8: .line 78
            aload 0 /* this */
            iload 4 /* maxConcurrency */
            putfield reactor.core.publisher.FluxFlatMap.maxConcurrency:I
         9: .line 79
            aload 0 /* this */
        10: .line 80
            aload 5 /* mainQueueSupplier */
            ldc "mainQueueSupplier"
            invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            checkcast java.util.function.Supplier
        11: .line 79
            putfield reactor.core.publisher.FluxFlatMap.mainQueueSupplier:Ljava/util/function/Supplier;
        12: .line 81
            aload 0 /* this */
        13: .line 82
            aload 7 /* innerQueueSupplier */
            ldc "innerQueueSupplier"
            invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            checkcast java.util.function.Supplier
        14: .line 81
            putfield reactor.core.publisher.FluxFlatMap.innerQueueSupplier:Ljava/util/function/Supplier;
        15: .line 83
            return
        end local 7 // java.util.function.Supplier innerQueueSupplier
        end local 6 // int prefetch
        end local 5 // java.util.function.Supplier mainQueueSupplier
        end local 4 // int maxConcurrency
        end local 3 // boolean delayError
        end local 2 // java.util.function.Function mapper
        end local 1 // reactor.core.publisher.Flux source
        end local 0 // reactor.core.publisher.FluxFlatMap this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0   16     0                this  Lreactor/core/publisher/FluxFlatMap<TT;TR;>;
            0   16     1              source  Lreactor/core/publisher/Flux<+TT;>;
            0   16     2              mapper  Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;
            0   16     3          delayError  Z
            0   16     4      maxConcurrency  I
            0   16     5   mainQueueSupplier  Ljava/util/function/Supplier<+Ljava/util/Queue<TR;>;>;
            0   16     6            prefetch  I
            0   16     7  innerQueueSupplier  Ljava/util/function/Supplier<+Ljava/util/Queue<TR;>;>;
    Signature: (Lreactor/core/publisher/Flux<+TT;>;Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;ZILjava/util/function/Supplier<+Ljava/util/Queue<TR;>;>;ILjava/util/function/Supplier<+Ljava/util/Queue<TR;>;>;)V
    MethodParameters:
                    Name  Flags
      source              
      mapper              
      delayError          
      maxConcurrency      
      mainQueueSupplier   
      prefetch            
      innerQueueSupplier  

  public int getPrefetch();
    descriptor: ()I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // reactor.core.publisher.FluxFlatMap this
         0: .line 87
            aload 0 /* this */
            getfield reactor.core.publisher.FluxFlatMap.prefetch:I
            ireturn
        end local 0 // reactor.core.publisher.FluxFlatMap this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lreactor/core/publisher/FluxFlatMap<TT;TR;>;

  public reactor.core.CoreSubscriber<? super T> subscribeOrReturn(reactor.core.CoreSubscriber<? super R>);
    descriptor: (Lreactor/core/CoreSubscriber;)Lreactor/core/CoreSubscriber;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=9, locals=2, args_size=2
        start local 0 // reactor.core.publisher.FluxFlatMap this
        start local 1 // reactor.core.CoreSubscriber actual
         0: .line 92
            aload 0 /* this */
            getfield reactor.core.publisher.FluxFlatMap.source:Lreactor/core/publisher/Flux;
            aload 1 /* actual */
            aload 0 /* this */
            getfield reactor.core.publisher.FluxFlatMap.mapper:Ljava/util/function/Function;
            iconst_0
            iconst_1
            invokestatic reactor.core.publisher.FluxFlatMap.trySubscribeScalarMap:(Lorg/reactivestreams/Publisher;Lreactor/core/CoreSubscriber;Ljava/util/function/Function;ZZ)Z
            ifeq 2
         1: .line 93
            aconst_null
            areturn
         2: .line 96
      StackMap locals:
      StackMap stack:
            new reactor.core.publisher.FluxFlatMap$FlatMapMain
            dup
            aload 1 /* actual */
         3: .line 97
            aload 0 /* this */
            getfield reactor.core.publisher.FluxFlatMap.mapper:Ljava/util/function/Function;
         4: .line 98
            aload 0 /* this */
            getfield reactor.core.publisher.FluxFlatMap.delayError:Z
         5: .line 99
            aload 0 /* this */
            getfield reactor.core.publisher.FluxFlatMap.maxConcurrency:I
         6: .line 100
            aload 0 /* this */
            getfield reactor.core.publisher.FluxFlatMap.mainQueueSupplier:Ljava/util/function/Supplier;
         7: .line 101
            aload 0 /* this */
            getfield reactor.core.publisher.FluxFlatMap.prefetch:I
            aload 0 /* this */
            getfield reactor.core.publisher.FluxFlatMap.innerQueueSupplier:Ljava/util/function/Supplier;
         8: .line 96
            invokespecial reactor.core.publisher.FluxFlatMap$FlatMapMain.<init>:(Lreactor/core/CoreSubscriber;Ljava/util/function/Function;ZILjava/util/function/Supplier;ILjava/util/function/Supplier;)V
            areturn
        end local 1 // reactor.core.CoreSubscriber actual
        end local 0 // reactor.core.publisher.FluxFlatMap this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    9     0    this  Lreactor/core/publisher/FluxFlatMap<TT;TR;>;
            0    9     1  actual  Lreactor/core/CoreSubscriber<-TR;>;
    Signature: (Lreactor/core/CoreSubscriber<-TR;>;)Lreactor/core/CoreSubscriber<-TT;>;
    MethodParameters:
        Name  Flags
      actual  

  static <T, R> boolean trySubscribeScalarMap(org.reactivestreams.Publisher<? extends T>, reactor.core.CoreSubscriber<? super R>, java.util.function.Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>>, boolean, );
    descriptor: (Lorg/reactivestreams/Publisher;Lreactor/core/CoreSubscriber;Ljava/util/function/Function;ZZ)Z
    flags: (0x0008) ACC_STATIC
    Code:
      stack=4, locals=11, args_size=5
        start local 0 // org.reactivestreams.Publisher source
        start local 1 // reactor.core.CoreSubscriber s
        start local 2 // java.util.function.Function mapper
        start local 3 // boolean fuseableExpected
        start local 4 // boolean errorContinueExpected
         0: .line 122
            aload 0 /* source */
            instanceof java.util.concurrent.Callable
            ifeq 56
         1: .line 126
            aload 0 /* source */
            checkcast java.util.concurrent.Callable
            invokeinterface java.util.concurrent.Callable.call:()Ljava/lang/Object;
            astore 5 /* t */
        start local 5 // java.lang.Object t
         2: .line 127
            goto 14
        end local 5 // java.lang.Object t
         3: .line 128
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 6 /* e */
        start local 6 // java.lang.Throwable e
         4: .line 129
            aload 1 /* s */
            invokeinterface reactor.core.CoreSubscriber.currentContext:()Lreactor/util/context/Context;
            astore 7 /* ctx */
        start local 7 // reactor.util.context.Context ctx
         5: .line 130
            iload 4 /* errorContinueExpected */
            ifeq 7
         6: .line 131
            aconst_null
            aload 6 /* e */
            aload 7 /* ctx */
            invokestatic reactor.core.publisher.Operators.onNextError:(Ljava/lang/Object;Ljava/lang/Throwable;Lreactor/util/context/Context;)Ljava/lang/Throwable;
            goto 8
         7: .line 132
      StackMap locals: org.reactivestreams.Publisher reactor.core.CoreSubscriber java.util.function.Function int int top java.lang.Throwable reactor.util.context.Context
      StackMap stack:
            aload 6 /* e */
            aload 7 /* ctx */
            invokestatic reactor.core.publisher.Operators.onOperatorError:(Ljava/lang/Throwable;Lreactor/util/context/Context;)Ljava/lang/Throwable;
         8: .line 130
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 8 /* e_ */
        start local 8 // java.lang.Throwable e_
         9: .line 133
            aload 8 /* e_ */
            ifnull 12
        10: .line 134
            aload 1 /* s */
            aload 8 /* e_ */
            invokestatic reactor.core.publisher.Operators.error:(Lorg/reactivestreams/Subscriber;Ljava/lang/Throwable;)V
        11: .line 135
            goto 13
        12: .line 138
      StackMap locals: java.lang.Throwable
      StackMap stack:
            aload 1 /* s */
            invokestatic reactor.core.publisher.Operators.complete:(Lorg/reactivestreams/Subscriber;)V
        13: .line 140
      StackMap locals:
      StackMap stack:
            iconst_1
            ireturn
        end local 8 // java.lang.Throwable e_
        end local 7 // reactor.util.context.Context ctx
        end local 6 // java.lang.Throwable e
        start local 5 // java.lang.Object t
        14: .line 143
      StackMap locals: org.reactivestreams.Publisher reactor.core.CoreSubscriber java.util.function.Function int int java.lang.Object
      StackMap stack:
            aload 5 /* t */
            ifnonnull 17
        15: .line 144
            aload 1 /* s */
            invokestatic reactor.core.publisher.Operators.complete:(Lorg/reactivestreams/Subscriber;)V
        16: .line 145
            iconst_1
            ireturn
        17: .line 151
      StackMap locals:
      StackMap stack:
            aload 2 /* mapper */
            aload 5 /* t */
            invokeinterface java.util.function.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast org.reactivestreams.Publisher
        18: .line 152
            ldc "The mapper returned a null Publisher"
        19: .line 151
            invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            checkcast org.reactivestreams.Publisher
            astore 6 /* p */
        start local 6 // org.reactivestreams.Publisher p
        20: .line 153
            goto 32
        end local 6 // org.reactivestreams.Publisher p
        21: .line 154
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 7 /* e */
        start local 7 // java.lang.Throwable e
        22: .line 155
            aload 1 /* s */
            invokeinterface reactor.core.CoreSubscriber.currentContext:()Lreactor/util/context/Context;
            astore 8 /* ctx */
        start local 8 // reactor.util.context.Context ctx
        23: .line 156
            iload 4 /* errorContinueExpected */
            ifeq 25
        24: .line 157
            aload 5 /* t */
            aload 7 /* e */
            aload 8 /* ctx */
            invokestatic reactor.core.publisher.Operators.onNextError:(Ljava/lang/Object;Ljava/lang/Throwable;Lreactor/util/context/Context;)Ljava/lang/Throwable;
            goto 26
        25: .line 158
      StackMap locals: org.reactivestreams.Publisher reactor.core.CoreSubscriber java.util.function.Function int int java.lang.Object top java.lang.Throwable reactor.util.context.Context
      StackMap stack:
            aconst_null
            aload 7 /* e */
            aload 5 /* t */
            aload 8 /* ctx */
            invokestatic reactor.core.publisher.Operators.onOperatorError:(Lorg/reactivestreams/Subscription;Ljava/lang/Throwable;Ljava/lang/Object;Lreactor/util/context/Context;)Ljava/lang/Throwable;
        26: .line 156
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 9 /* e_ */
        start local 9 // java.lang.Throwable e_
        27: .line 159
            aload 9 /* e_ */
            ifnull 30
        28: .line 160
            aload 1 /* s */
            aload 9 /* e_ */
            invokestatic reactor.core.publisher.Operators.error:(Lorg/reactivestreams/Subscriber;Ljava/lang/Throwable;)V
        29: .line 161
            goto 31
        30: .line 164
      StackMap locals: java.lang.Throwable
      StackMap stack:
            aload 1 /* s */
            invokestatic reactor.core.publisher.Operators.complete:(Lorg/reactivestreams/Subscriber;)V
        31: .line 166
      StackMap locals:
      StackMap stack:
            iconst_1
            ireturn
        end local 9 // java.lang.Throwable e_
        end local 8 // reactor.util.context.Context ctx
        end local 7 // java.lang.Throwable e
        start local 6 // org.reactivestreams.Publisher p
        32: .line 169
      StackMap locals: org.reactivestreams.Publisher reactor.core.CoreSubscriber java.util.function.Function int int java.lang.Object org.reactivestreams.Publisher
      StackMap stack:
            aload 6 /* p */
            instanceof java.util.concurrent.Callable
            ifeq 51
        33: .line 173
            aload 6 /* p */
            checkcast java.util.concurrent.Callable
            invokeinterface java.util.concurrent.Callable.call:()Ljava/lang/Object;
            astore 7 /* v */
        start local 7 // java.lang.Object v
        34: .line 174
            goto 46
        end local 7 // java.lang.Object v
        35: .line 175
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 8 /* e */
        start local 8 // java.lang.Throwable e
        36: .line 176
            aload 1 /* s */
            invokeinterface reactor.core.CoreSubscriber.currentContext:()Lreactor/util/context/Context;
            astore 9 /* ctx */
        start local 9 // reactor.util.context.Context ctx
        37: .line 177
            iload 4 /* errorContinueExpected */
            ifeq 39
        38: .line 178
            aload 5 /* t */
            aload 8 /* e */
            aload 9 /* ctx */
            invokestatic reactor.core.publisher.Operators.onNextError:(Ljava/lang/Object;Ljava/lang/Throwable;Lreactor/util/context/Context;)Ljava/lang/Throwable;
            goto 40
        39: .line 179
      StackMap locals: org.reactivestreams.Publisher reactor.core.CoreSubscriber java.util.function.Function int int java.lang.Object org.reactivestreams.Publisher top java.lang.Throwable reactor.util.context.Context
      StackMap stack:
            aconst_null
            aload 8 /* e */
            aload 5 /* t */
            aload 9 /* ctx */
            invokestatic reactor.core.publisher.Operators.onOperatorError:(Lorg/reactivestreams/Subscription;Ljava/lang/Throwable;Ljava/lang/Object;Lreactor/util/context/Context;)Ljava/lang/Throwable;
        40: .line 177
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 10 /* e_ */
        start local 10 // java.lang.Throwable e_
        41: .line 180
            aload 10 /* e_ */
            ifnull 44
        42: .line 181
            aload 1 /* s */
            aload 10 /* e_ */
            invokestatic reactor.core.publisher.Operators.error:(Lorg/reactivestreams/Subscriber;Ljava/lang/Throwable;)V
        43: .line 182
            goto 45
        44: .line 185
      StackMap locals: java.lang.Throwable
      StackMap stack:
            aload 1 /* s */
            invokestatic reactor.core.publisher.Operators.complete:(Lorg/reactivestreams/Subscriber;)V
        45: .line 187
      StackMap locals:
      StackMap stack:
            iconst_1
            ireturn
        end local 10 // java.lang.Throwable e_
        end local 9 // reactor.util.context.Context ctx
        end local 8 // java.lang.Throwable e
        start local 7 // java.lang.Object v
        46: .line 190
      StackMap locals: org.reactivestreams.Publisher reactor.core.CoreSubscriber java.util.function.Function int int java.lang.Object org.reactivestreams.Publisher java.lang.Object
      StackMap stack:
            aload 7 /* v */
            ifnull 49
        47: .line 191
            aload 1 /* s */
            aload 1 /* s */
            aload 7 /* v */
            invokestatic reactor.core.publisher.Operators.scalarSubscription:(Lreactor/core/CoreSubscriber;Ljava/lang/Object;)Lorg/reactivestreams/Subscription;
            invokeinterface reactor.core.CoreSubscriber.onSubscribe:(Lorg/reactivestreams/Subscription;)V
        48: .line 192
            goto 55
        49: .line 194
      StackMap locals:
      StackMap stack:
            aload 1 /* s */
            invokestatic reactor.core.publisher.Operators.complete:(Lorg/reactivestreams/Subscriber;)V
        end local 7 // java.lang.Object v
        50: .line 196
            goto 55
        51: .line 198
      StackMap locals:
      StackMap stack:
            iload 3 /* fuseableExpected */
            ifeq 52
            aload 6 /* p */
            instanceof reactor.core.Fuseable
            ifeq 54
        52: .line 199
      StackMap locals:
      StackMap stack:
            aload 6 /* p */
            aload 1 /* s */
            invokeinterface org.reactivestreams.Publisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
        53: .line 200
            goto 55
        54: .line 202
      StackMap locals:
      StackMap stack:
            aload 6 /* p */
            new reactor.core.publisher.FluxHide$SuppressFuseableSubscriber
            dup
            aload 1 /* s */
            invokespecial reactor.core.publisher.FluxHide$SuppressFuseableSubscriber.<init>:(Lreactor/core/CoreSubscriber;)V
            invokeinterface org.reactivestreams.Publisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
        55: .line 206
      StackMap locals:
      StackMap stack:
            iconst_1
            ireturn
        end local 6 // org.reactivestreams.Publisher p
        end local 5 // java.lang.Object t
        56: .line 209
      StackMap locals:
      StackMap stack:
            iconst_0
            ireturn
        end local 4 // boolean errorContinueExpected
        end local 3 // boolean fuseableExpected
        end local 2 // java.util.function.Function mapper
        end local 1 // reactor.core.CoreSubscriber s
        end local 0 // org.reactivestreams.Publisher source
      LocalVariableTable:
        Start  End  Slot                   Name  Signature
            0   57     0                 source  Lorg/reactivestreams/Publisher<+TT;>;
            0   57     1                      s  Lreactor/core/CoreSubscriber<-TR;>;
            0   57     2                 mapper  Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;
            0   57     3       fuseableExpected  Z
            0   57     4  errorContinueExpected  Z
            2    3     5                      t  TT;
           14   56     5                      t  TT;
            4   14     6                      e  Ljava/lang/Throwable;
            5   14     7                    ctx  Lreactor/util/context/Context;
            9   14     8                     e_  Ljava/lang/Throwable;
           20   21     6                      p  Lorg/reactivestreams/Publisher<+TR;>;
           32   56     6                      p  Lorg/reactivestreams/Publisher<+TR;>;
           22   32     7                      e  Ljava/lang/Throwable;
           23   32     8                    ctx  Lreactor/util/context/Context;
           27   32     9                     e_  Ljava/lang/Throwable;
           34   35     7                      v  TR;
           46   50     7                      v  TR;
           36   46     8                      e  Ljava/lang/Throwable;
           37   46     9                    ctx  Lreactor/util/context/Context;
           41   46    10                     e_  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           1     2       3  Class java.lang.Throwable
          17    20      21  Class java.lang.Throwable
          33    34      35  Class java.lang.Throwable
    Signature: <T:Ljava/lang/Object;R:Ljava/lang/Object;>(Lorg/reactivestreams/Publisher<+TT;>;Lreactor/core/CoreSubscriber<-TR;>;Ljava/util/function/Function<-TT;+Lorg/reactivestreams/Publisher<+TR;>;>;ZZ)Z
    MethodParameters:
                       Name  Flags
      source                 
      s                      
      mapper                 
      fuseableExpected       
      errorContinueExpected  

  public java.lang.Object scanUnsafe(reactor.core.Scannable$Attr);
    descriptor: (Lreactor/core/Scannable$Attr;)Ljava/lang/Object;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // reactor.core.publisher.FluxFlatMap this
        start local 1 // reactor.core.Scannable$Attr key
         0: .line 214
            aload 1 /* key */
            getstatic reactor.core.Scannable$Attr.RUN_STYLE:Lreactor/core/Scannable$Attr;
            if_acmpne 1
            getstatic reactor.core.Scannable$Attr$RunStyle.SYNC:Lreactor/core/Scannable$Attr$RunStyle;
            areturn
         1: .line 215
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* key */
            invokespecial reactor.core.publisher.InternalFluxOperator.scanUnsafe:(Lreactor/core/Scannable$Attr;)Ljava/lang/Object;
            areturn
        end local 1 // reactor.core.Scannable$Attr key
        end local 0 // reactor.core.publisher.FluxFlatMap this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lreactor/core/publisher/FluxFlatMap<TT;TR;>;
            0    2     1   key  Lreactor/core/Scannable$Attr;
    MethodParameters:
      Name  Flags
      key   
}
Signature: <T:Ljava/lang/Object;R:Ljava/lang/Object;>Lreactor/core/publisher/InternalFluxOperator<TT;TR;>;
SourceFile: "FluxFlatMap.java"
NestMembers:
  reactor.core.publisher.FluxFlatMap$FlatMapInner  reactor.core.publisher.FluxFlatMap$FlatMapMain
InnerClasses:
  public Attr = reactor.core.Scannable$Attr of reactor.core.Scannable
  public final RunStyle = reactor.core.Scannable$Attr$RunStyle of reactor.core.Scannable$Attr
  final FlatMapInner = reactor.core.publisher.FluxFlatMap$FlatMapInner of reactor.core.publisher.FluxFlatMap
  final FlatMapMain = reactor.core.publisher.FluxFlatMap$FlatMapMain of reactor.core.publisher.FluxFlatMap
  final SuppressFuseableSubscriber = reactor.core.publisher.FluxHide$SuppressFuseableSubscriber of reactor.core.publisher.FluxHide