class org.springframework.core.ReactiveAdapterRegistry$RxJava2Registrar
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: org.springframework.core.ReactiveAdapterRegistry$RxJava2Registrar
  super_class: java.lang.Object
{
  private void <init>();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.springframework.core.ReactiveAdapterRegistry$RxJava2Registrar this
         0: .line 237
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
            return
        end local 0 // org.springframework.core.ReactiveAdapterRegistry$RxJava2Registrar this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/springframework/core/ReactiveAdapterRegistry$RxJava2Registrar;

  void registerAdapters(org.springframework.core.ReactiveAdapterRegistry);
    descriptor: (Lorg/springframework/core/ReactiveAdapterRegistry;)V
    flags: (0x0000) 
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // org.springframework.core.ReactiveAdapterRegistry$RxJava2Registrar this
        start local 1 // org.springframework.core.ReactiveAdapterRegistry registry
         0: .line 240
            aload 1 /* registry */
         1: .line 241
            ldc Lio/reactivex/Flowable;
            invokedynamic get()Ljava/util/function/Supplier;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  ()Ljava/lang/Object;
                  io/reactivex/Flowable.empty()Lio/reactivex/Flowable; (6)
                  ()Ljava/lang/Object;
            invokestatic org.springframework.core.ReactiveTypeDescriptor.multiValue:(Ljava/lang/Class;Ljava/util/function/Supplier;)Lorg/springframework/core/ReactiveTypeDescriptor;
         2: .line 242
            invokedynamic apply()Ljava/util/function/Function;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)Ljava/lang/Object;
                  org/springframework/core/ReactiveAdapterRegistry$RxJava2Registrar.lambda$1(Ljava/lang/Object;)Lorg/reactivestreams/Publisher; (6)
                  (Ljava/lang/Object;)Lorg/reactivestreams/Publisher;
         3: .line 243
            invokedynamic apply()Ljava/util/function/Function;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)Ljava/lang/Object;
                  io/reactivex/Flowable.fromPublisher(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable; (6)
                  (Lorg/reactivestreams/Publisher;)Ljava/lang/Object;
         4: .line 240
            invokevirtual org.springframework.core.ReactiveAdapterRegistry.registerReactiveType:(Lorg/springframework/core/ReactiveTypeDescriptor;Ljava/util/function/Function;Ljava/util/function/Function;)V
         5: .line 245
            aload 1 /* registry */
         6: .line 246
            ldc Lio/reactivex/Observable;
            invokedynamic get()Ljava/util/function/Supplier;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  ()Ljava/lang/Object;
                  io/reactivex/Observable.empty()Lio/reactivex/Observable; (6)
                  ()Ljava/lang/Object;
            invokestatic org.springframework.core.ReactiveTypeDescriptor.multiValue:(Ljava/lang/Class;Ljava/util/function/Supplier;)Lorg/springframework/core/ReactiveTypeDescriptor;
         7: .line 247
            invokedynamic apply()Ljava/util/function/Function;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)Ljava/lang/Object;
                  org/springframework/core/ReactiveAdapterRegistry$RxJava2Registrar.lambda$4(Ljava/lang/Object;)Lorg/reactivestreams/Publisher; (6)
                  (Ljava/lang/Object;)Lorg/reactivestreams/Publisher;
         8: .line 248
            invokedynamic apply()Ljava/util/function/Function;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)Ljava/lang/Object;
                  org/springframework/core/ReactiveAdapterRegistry$RxJava2Registrar.lambda$5(Lorg/reactivestreams/Publisher;)Ljava/lang/Object; (6)
                  (Lorg/reactivestreams/Publisher;)Ljava/lang/Object;
         9: .line 245
            invokevirtual org.springframework.core.ReactiveAdapterRegistry.registerReactiveType:(Lorg/springframework/core/ReactiveTypeDescriptor;Ljava/util/function/Function;Ljava/util/function/Function;)V
        10: .line 250
            aload 1 /* registry */
        11: .line 251
            ldc Lio/reactivex/Single;
            invokestatic org.springframework.core.ReactiveTypeDescriptor.singleRequiredValue:(Ljava/lang/Class;)Lorg/springframework/core/ReactiveTypeDescriptor;
        12: .line 252
            invokedynamic apply()Ljava/util/function/Function;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)Ljava/lang/Object;
                  org/springframework/core/ReactiveAdapterRegistry$RxJava2Registrar.lambda$6(Ljava/lang/Object;)Lorg/reactivestreams/Publisher; (6)
                  (Ljava/lang/Object;)Lorg/reactivestreams/Publisher;
        13: .line 253
            invokedynamic apply()Ljava/util/function/Function;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)Ljava/lang/Object;
                  org/springframework/core/ReactiveAdapterRegistry$RxJava2Registrar.lambda$7(Lorg/reactivestreams/Publisher;)Ljava/lang/Object; (6)
                  (Lorg/reactivestreams/Publisher;)Ljava/lang/Object;
        14: .line 250
            invokevirtual org.springframework.core.ReactiveAdapterRegistry.registerReactiveType:(Lorg/springframework/core/ReactiveTypeDescriptor;Ljava/util/function/Function;Ljava/util/function/Function;)V
        15: .line 255
            aload 1 /* registry */
        16: .line 256
            ldc Lio/reactivex/Maybe;
            invokedynamic get()Ljava/util/function/Supplier;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  ()Ljava/lang/Object;
                  io/reactivex/Maybe.empty()Lio/reactivex/Maybe; (6)
                  ()Ljava/lang/Object;
            invokestatic org.springframework.core.ReactiveTypeDescriptor.singleOptionalValue:(Ljava/lang/Class;Ljava/util/function/Supplier;)Lorg/springframework/core/ReactiveTypeDescriptor;
        17: .line 257
            invokedynamic apply()Ljava/util/function/Function;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)Ljava/lang/Object;
                  org/springframework/core/ReactiveAdapterRegistry$RxJava2Registrar.lambda$9(Ljava/lang/Object;)Lorg/reactivestreams/Publisher; (6)
                  (Ljava/lang/Object;)Lorg/reactivestreams/Publisher;
        18: .line 258
            invokedynamic apply()Ljava/util/function/Function;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)Ljava/lang/Object;
                  org/springframework/core/ReactiveAdapterRegistry$RxJava2Registrar.lambda$10(Lorg/reactivestreams/Publisher;)Ljava/lang/Object; (6)
                  (Lorg/reactivestreams/Publisher;)Ljava/lang/Object;
        19: .line 255
            invokevirtual org.springframework.core.ReactiveAdapterRegistry.registerReactiveType:(Lorg/springframework/core/ReactiveTypeDescriptor;Ljava/util/function/Function;Ljava/util/function/Function;)V
        20: .line 260
            aload 1 /* registry */
        21: .line 261
            ldc Lio/reactivex/Completable;
            invokedynamic get()Ljava/util/function/Supplier;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  ()Ljava/lang/Object;
                  io/reactivex/Completable.complete()Lio/reactivex/Completable; (6)
                  ()Ljava/lang/Object;
            invokestatic org.springframework.core.ReactiveTypeDescriptor.noValue:(Ljava/lang/Class;Ljava/util/function/Supplier;)Lorg/springframework/core/ReactiveTypeDescriptor;
        22: .line 262
            invokedynamic apply()Ljava/util/function/Function;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)Ljava/lang/Object;
                  org/springframework/core/ReactiveAdapterRegistry$RxJava2Registrar.lambda$12(Ljava/lang/Object;)Lorg/reactivestreams/Publisher; (6)
                  (Ljava/lang/Object;)Lorg/reactivestreams/Publisher;
        23: .line 263
            invokedynamic apply()Ljava/util/function/Function;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)Ljava/lang/Object;
                  org/springframework/core/ReactiveAdapterRegistry$RxJava2Registrar.lambda$13(Lorg/reactivestreams/Publisher;)Ljava/lang/Object; (6)
                  (Lorg/reactivestreams/Publisher;)Ljava/lang/Object;
        24: .line 260
            invokevirtual org.springframework.core.ReactiveAdapterRegistry.registerReactiveType:(Lorg/springframework/core/ReactiveTypeDescriptor;Ljava/util/function/Function;Ljava/util/function/Function;)V
        25: .line 265
            return
        end local 1 // org.springframework.core.ReactiveAdapterRegistry registry
        end local 0 // org.springframework.core.ReactiveAdapterRegistry$RxJava2Registrar this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   26     0      this  Lorg/springframework/core/ReactiveAdapterRegistry$RxJava2Registrar;
            0   26     1  registry  Lorg/springframework/core/ReactiveAdapterRegistry;
    MethodParameters:
          Name  Flags
      registry  

  private static org.reactivestreams.Publisher lambda$1(java.lang.Object);
    descriptor: (Ljava/lang/Object;)Lorg/reactivestreams/Publisher;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // java.lang.Object source
         0: .line 242
            aload 0 /* source */
            checkcast io.reactivex.Flowable
            areturn
        end local 0 // java.lang.Object source
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0  source  Ljava/lang/Object;

  private static org.reactivestreams.Publisher lambda$4(java.lang.Object);
    descriptor: (Ljava/lang/Object;)Lorg/reactivestreams/Publisher;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.lang.Object source
         0: .line 247
            aload 0 /* source */
            checkcast io.reactivex.Observable
            getstatic io.reactivex.BackpressureStrategy.BUFFER:Lio/reactivex/BackpressureStrategy;
            invokevirtual io.reactivex.Observable.toFlowable:(Lio/reactivex/BackpressureStrategy;)Lio/reactivex/Flowable;
            areturn
        end local 0 // java.lang.Object source
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0  source  Ljava/lang/Object;

  private static java.lang.Object lambda$5(org.reactivestreams.Publisher);
    descriptor: (Lorg/reactivestreams/Publisher;)Ljava/lang/Object;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.reactivestreams.Publisher source
         0: .line 248
            aload 0 /* source */
            invokestatic io.reactivex.Flowable.fromPublisher:(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable;
            invokevirtual io.reactivex.Flowable.toObservable:()Lio/reactivex/Observable;
            areturn
        end local 0 // org.reactivestreams.Publisher source
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0  source  Lorg/reactivestreams/Publisher<*>;

  private static org.reactivestreams.Publisher lambda$6(java.lang.Object);
    descriptor: (Ljava/lang/Object;)Lorg/reactivestreams/Publisher;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // java.lang.Object source
         0: .line 252
            aload 0 /* source */
            checkcast io.reactivex.Single
            invokevirtual io.reactivex.Single.toFlowable:()Lio/reactivex/Flowable;
            areturn
        end local 0 // java.lang.Object source
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0  source  Ljava/lang/Object;

  private static java.lang.Object lambda$7(org.reactivestreams.Publisher);
    descriptor: (Lorg/reactivestreams/Publisher;)Ljava/lang/Object;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.reactivestreams.Publisher source
         0: .line 253
            aload 0 /* source */
            invokestatic io.reactivex.Flowable.fromPublisher:(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable;
            invokevirtual io.reactivex.Flowable.toObservable:()Lio/reactivex/Observable;
            invokevirtual io.reactivex.Observable.singleElement:()Lio/reactivex/Maybe;
            invokevirtual io.reactivex.Maybe.toSingle:()Lio/reactivex/Single;
            areturn
        end local 0 // org.reactivestreams.Publisher source
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0  source  Lorg/reactivestreams/Publisher<*>;

  private static org.reactivestreams.Publisher lambda$9(java.lang.Object);
    descriptor: (Ljava/lang/Object;)Lorg/reactivestreams/Publisher;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // java.lang.Object source
         0: .line 257
            aload 0 /* source */
            checkcast io.reactivex.Maybe
            invokevirtual io.reactivex.Maybe.toFlowable:()Lio/reactivex/Flowable;
            areturn
        end local 0 // java.lang.Object source
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0  source  Ljava/lang/Object;

  private static java.lang.Object lambda$10(org.reactivestreams.Publisher);
    descriptor: (Lorg/reactivestreams/Publisher;)Ljava/lang/Object;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.reactivestreams.Publisher source
         0: .line 258
            aload 0 /* source */
            invokestatic io.reactivex.Flowable.fromPublisher:(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable;
            invokevirtual io.reactivex.Flowable.toObservable:()Lio/reactivex/Observable;
            invokevirtual io.reactivex.Observable.singleElement:()Lio/reactivex/Maybe;
            areturn
        end local 0 // org.reactivestreams.Publisher source
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0  source  Lorg/reactivestreams/Publisher<*>;

  private static org.reactivestreams.Publisher lambda$12(java.lang.Object);
    descriptor: (Ljava/lang/Object;)Lorg/reactivestreams/Publisher;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // java.lang.Object source
         0: .line 262
            aload 0 /* source */
            checkcast io.reactivex.Completable
            invokevirtual io.reactivex.Completable.toFlowable:()Lio/reactivex/Flowable;
            areturn
        end local 0 // java.lang.Object source
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0  source  Ljava/lang/Object;

  private static java.lang.Object lambda$13(org.reactivestreams.Publisher);
    descriptor: (Lorg/reactivestreams/Publisher;)Ljava/lang/Object;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.reactivestreams.Publisher source
         0: .line 263
            aload 0 /* source */
            invokestatic io.reactivex.Flowable.fromPublisher:(Lorg/reactivestreams/Publisher;)Lio/reactivex/Flowable;
            invokevirtual io.reactivex.Flowable.toObservable:()Lio/reactivex/Observable;
            invokevirtual io.reactivex.Observable.ignoreElements:()Lio/reactivex/Completable;
            areturn
        end local 0 // org.reactivestreams.Publisher source
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0  source  Lorg/reactivestreams/Publisher<*>;
}
SourceFile: "ReactiveAdapterRegistry.java"
NestHost: org.springframework.core.ReactiveAdapterRegistry
InnerClasses:
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
  private RxJava2Registrar = org.springframework.core.ReactiveAdapterRegistry$RxJava2Registrar of org.springframework.core.ReactiveAdapterRegistry