final class io.reactivex.internal.operators.flowable.FlowableReplay$MulticastFlowable<R, U> extends io.reactivex.Flowable<R>
  minor version: 0
  major version: 59
  flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
  this_class: io.reactivex.internal.operators.flowable.FlowableReplay$MulticastFlowable
  super_class: io.reactivex.Flowable
{
  private final java.util.concurrent.Callable<? extends io.reactivex.flowables.ConnectableFlowable<U>> connectableFactory;
    descriptor: Ljava/util/concurrent/Callable;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/concurrent/Callable<+Lio/reactivex/flowables/ConnectableFlowable<TU;>;>;

  private final io.reactivex.functions.Function<? super io.reactivex.Flowable<U>, ? extends org.reactivestreams.Publisher<R>> selector;
    descriptor: Lio/reactivex/functions/Function;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Lio/reactivex/functions/Function<-Lio/reactivex/Flowable<TU;>;+Lorg/reactivestreams/Publisher<TR;>;>;

  void <init>(java.util.concurrent.Callable<? extends io.reactivex.flowables.ConnectableFlowable<U>>, io.reactivex.functions.Function<? super io.reactivex.Flowable<U>, ? extends org.reactivestreams.Publisher<R>>);
    descriptor: (Ljava/util/concurrent/Callable;Lio/reactivex/functions/Function;)V
    flags: (0x0000) 
    Code:
      stack=2, locals=3, args_size=3
        start local 0 // io.reactivex.internal.operators.flowable.FlowableReplay$MulticastFlowable this
        start local 1 // java.util.concurrent.Callable connectableFactory
        start local 2 // io.reactivex.functions.Function selector
         0: .line 1104
            aload 0 /* this */
            invokespecial io.reactivex.Flowable.<init>:()V
         1: .line 1105
            aload 0 /* this */
            aload 1 /* connectableFactory */
            putfield io.reactivex.internal.operators.flowable.FlowableReplay$MulticastFlowable.connectableFactory:Ljava/util/concurrent/Callable;
         2: .line 1106
            aload 0 /* this */
            aload 2 /* selector */
            putfield io.reactivex.internal.operators.flowable.FlowableReplay$MulticastFlowable.selector:Lio/reactivex/functions/Function;
         3: .line 1107
            return
        end local 2 // io.reactivex.functions.Function selector
        end local 1 // java.util.concurrent.Callable connectableFactory
        end local 0 // io.reactivex.internal.operators.flowable.FlowableReplay$MulticastFlowable this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0    4     0                this  Lio/reactivex/internal/operators/flowable/FlowableReplay$MulticastFlowable<TR;TU;>;
            0    4     1  connectableFactory  Ljava/util/concurrent/Callable<+Lio/reactivex/flowables/ConnectableFlowable<TU;>;>;
            0    4     2            selector  Lio/reactivex/functions/Function<-Lio/reactivex/Flowable<TU;>;+Lorg/reactivestreams/Publisher<TR;>;>;
    Signature: (Ljava/util/concurrent/Callable<+Lio/reactivex/flowables/ConnectableFlowable<TU;>;>;Lio/reactivex/functions/Function<-Lio/reactivex/Flowable<TU;>;+Lorg/reactivestreams/Publisher<TR;>;>;)V
    MethodParameters:
                    Name  Flags
      connectableFactory  
      selector            

  protected void subscribeActual(org.reactivestreams.Subscriber<? super R>);
    descriptor: (Lorg/reactivestreams/Subscriber;)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=5, locals=5, args_size=2
        start local 0 // io.reactivex.internal.operators.flowable.FlowableReplay$MulticastFlowable this
        start local 1 // org.reactivestreams.Subscriber child
         0: .line 1113
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableReplay$MulticastFlowable.connectableFactory:Ljava/util/concurrent/Callable;
            invokeinterface java.util.concurrent.Callable.call:()Ljava/lang/Object;
            checkcast io.reactivex.flowables.ConnectableFlowable
            ldc "The connectableFactory returned null"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            checkcast io.reactivex.flowables.ConnectableFlowable
            astore 2 /* cf */
        start local 2 // io.reactivex.flowables.ConnectableFlowable cf
         1: .line 1114
            goto 6
        end local 2 // io.reactivex.flowables.ConnectableFlowable cf
      StackMap locals:
      StackMap stack: java.lang.Throwable
         2: astore 3 /* e */
        start local 3 // java.lang.Throwable e
         3: .line 1115
            aload 3 /* e */
            invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
         4: .line 1116
            aload 3 /* e */
            aload 1 /* child */
            invokestatic io.reactivex.internal.subscriptions.EmptySubscription.error:(Ljava/lang/Throwable;Lorg/reactivestreams/Subscriber;)V
         5: .line 1117
            return
        end local 3 // java.lang.Throwable e
        start local 2 // io.reactivex.flowables.ConnectableFlowable cf
         6: .line 1122
      StackMap locals: io.reactivex.flowables.ConnectableFlowable
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.operators.flowable.FlowableReplay$MulticastFlowable.selector:Lio/reactivex/functions/Function;
            aload 2 /* cf */
            invokeinterface io.reactivex.functions.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast org.reactivestreams.Publisher
            ldc "The selector returned a null Publisher"
            invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            checkcast org.reactivestreams.Publisher
            astore 3 /* observable */
        start local 3 // org.reactivestreams.Publisher observable
         7: .line 1123
            goto 12
        end local 3 // org.reactivestreams.Publisher observable
      StackMap locals:
      StackMap stack: java.lang.Throwable
         8: astore 4 /* e */
        start local 4 // java.lang.Throwable e
         9: .line 1124
            aload 4 /* e */
            invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
        10: .line 1125
            aload 4 /* e */
            aload 1 /* child */
            invokestatic io.reactivex.internal.subscriptions.EmptySubscription.error:(Ljava/lang/Throwable;Lorg/reactivestreams/Subscriber;)V
        11: .line 1126
            return
        end local 4 // java.lang.Throwable e
        start local 3 // org.reactivestreams.Publisher observable
        12: .line 1129
      StackMap locals: org.reactivestreams.Publisher
      StackMap stack:
            new io.reactivex.internal.subscribers.SubscriberResourceWrapper
            dup
            aload 1 /* child */
            invokespecial io.reactivex.internal.subscribers.SubscriberResourceWrapper.<init>:(Lorg/reactivestreams/Subscriber;)V
            astore 4 /* srw */
        start local 4 // io.reactivex.internal.subscribers.SubscriberResourceWrapper srw
        13: .line 1131
            aload 3 /* observable */
            aload 4 /* srw */
            invokeinterface org.reactivestreams.Publisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
        14: .line 1133
            aload 2 /* cf */
            new io.reactivex.internal.operators.flowable.FlowableReplay$MulticastFlowable$DisposableConsumer
            dup
            aload 0 /* this */
            aload 4 /* srw */
            invokespecial io.reactivex.internal.operators.flowable.FlowableReplay$MulticastFlowable$DisposableConsumer.<init>:(Lio/reactivex/internal/operators/flowable/FlowableReplay$MulticastFlowable;Lio/reactivex/internal/subscribers/SubscriberResourceWrapper;)V
            invokevirtual io.reactivex.flowables.ConnectableFlowable.connect:(Lio/reactivex/functions/Consumer;)V
        15: .line 1134
            return
        end local 4 // io.reactivex.internal.subscribers.SubscriberResourceWrapper srw
        end local 3 // org.reactivestreams.Publisher observable
        end local 2 // io.reactivex.flowables.ConnectableFlowable cf
        end local 1 // org.reactivestreams.Subscriber child
        end local 0 // io.reactivex.internal.operators.flowable.FlowableReplay$MulticastFlowable this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   16     0        this  Lio/reactivex/internal/operators/flowable/FlowableReplay$MulticastFlowable<TR;TU;>;
            0   16     1       child  Lorg/reactivestreams/Subscriber<-TR;>;
            1    2     2          cf  Lio/reactivex/flowables/ConnectableFlowable<TU;>;
            6   16     2          cf  Lio/reactivex/flowables/ConnectableFlowable<TU;>;
            3    6     3           e  Ljava/lang/Throwable;
            7    8     3  observable  Lorg/reactivestreams/Publisher<TR;>;
           12   16     3  observable  Lorg/reactivestreams/Publisher<TR;>;
            9   12     4           e  Ljava/lang/Throwable;
           13   16     4         srw  Lio/reactivex/internal/subscribers/SubscriberResourceWrapper<TR;>;
      Exception table:
        from    to  target  type
           0     1       2  Class java.lang.Throwable
           6     7       8  Class java.lang.Throwable
    Signature: (Lorg/reactivestreams/Subscriber<-TR;>;)V
    MethodParameters:
       Name  Flags
      child  
}
Signature: <R:Ljava/lang/Object;U:Ljava/lang/Object;>Lio/reactivex/Flowable<TR;>;
SourceFile: "FlowableReplay.java"
NestHost: io.reactivex.internal.operators.flowable.FlowableReplay
InnerClasses:
  final MulticastFlowable = io.reactivex.internal.operators.flowable.FlowableReplay$MulticastFlowable of io.reactivex.internal.operators.flowable.FlowableReplay
  final DisposableConsumer = io.reactivex.internal.operators.flowable.FlowableReplay$MulticastFlowable$DisposableConsumer of io.reactivex.internal.operators.flowable.FlowableReplay$MulticastFlowable