class org.springframework.core.ReactiveAdapterRegistry$ReactorRegistrar
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: org.springframework.core.ReactiveAdapterRegistry$ReactorRegistrar
  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$ReactorRegistrar this
         0: .line 181
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
            return
        end local 0 // org.springframework.core.ReactiveAdapterRegistry$ReactorRegistrar this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/springframework/core/ReactiveAdapterRegistry$ReactorRegistrar;

  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$ReactorRegistrar this
        start local 1 // org.springframework.core.ReactiveAdapterRegistry registry
         0: .line 186
            aload 1 /* registry */
         1: .line 187
            ldc Lreactor/core/publisher/Mono;
            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;
                  reactor/core/publisher/Mono.empty()Lreactor/core/publisher/Mono; (6)
                  ()Ljava/lang/Object;
            invokestatic org.springframework.core.ReactiveTypeDescriptor.singleOptionalValue:(Ljava/lang/Class;Ljava/util/function/Supplier;)Lorg/springframework/core/ReactiveTypeDescriptor;
         2: .line 188
            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$ReactorRegistrar.lambda$1(Ljava/lang/Object;)Lorg/reactivestreams/Publisher; (6)
                  (Ljava/lang/Object;)Lorg/reactivestreams/Publisher;
         3: .line 189
            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;
                  reactor/core/publisher/Mono.from(Lorg/reactivestreams/Publisher;)Lreactor/core/publisher/Mono; (6)
                  (Lorg/reactivestreams/Publisher;)Ljava/lang/Object;
         4: .line 186
            invokevirtual org.springframework.core.ReactiveAdapterRegistry.registerReactiveType:(Lorg/springframework/core/ReactiveTypeDescriptor;Ljava/util/function/Function;Ljava/util/function/Function;)V
         5: .line 192
            aload 1 /* registry */
         6: .line 193
            ldc Lreactor/core/publisher/Flux;
            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;
                  reactor/core/publisher/Flux.empty()Lreactor/core/publisher/Flux; (6)
                  ()Ljava/lang/Object;
            invokestatic org.springframework.core.ReactiveTypeDescriptor.multiValue:(Ljava/lang/Class;Ljava/util/function/Supplier;)Lorg/springframework/core/ReactiveTypeDescriptor;
         7: .line 194
            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$ReactorRegistrar.lambda$4(Ljava/lang/Object;)Lorg/reactivestreams/Publisher; (6)
                  (Ljava/lang/Object;)Lorg/reactivestreams/Publisher;
         8: .line 195
            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;
                  reactor/core/publisher/Flux.from(Lorg/reactivestreams/Publisher;)Lreactor/core/publisher/Flux; (6)
                  (Lorg/reactivestreams/Publisher;)Ljava/lang/Object;
         9: .line 192
            invokevirtual org.springframework.core.ReactiveAdapterRegistry.registerReactiveType:(Lorg/springframework/core/ReactiveTypeDescriptor;Ljava/util/function/Function;Ljava/util/function/Function;)V
        10: .line 197
            aload 1 /* registry */
        11: .line 198
            ldc Lorg/reactivestreams/Publisher;
            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;
                  reactor/core/publisher/Flux.empty()Lreactor/core/publisher/Flux; (6)
                  ()Ljava/lang/Object;
            invokestatic org.springframework.core.ReactiveTypeDescriptor.multiValue:(Ljava/lang/Class;Ljava/util/function/Supplier;)Lorg/springframework/core/ReactiveTypeDescriptor;
        12: .line 199
            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$ReactorRegistrar.lambda$7(Ljava/lang/Object;)Lorg/reactivestreams/Publisher; (6)
                  (Ljava/lang/Object;)Lorg/reactivestreams/Publisher;
        13: .line 200
            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$ReactorRegistrar.lambda$8(Lorg/reactivestreams/Publisher;)Ljava/lang/Object; (6)
                  (Lorg/reactivestreams/Publisher;)Ljava/lang/Object;
        14: .line 197
            invokevirtual org.springframework.core.ReactiveAdapterRegistry.registerReactiveType:(Lorg/springframework/core/ReactiveTypeDescriptor;Ljava/util/function/Function;Ljava/util/function/Function;)V
        15: .line 202
            aload 1 /* registry */
        16: .line 203
            ldc Ljava/util/concurrent/CompletableFuture;
            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;
                  org/springframework/core/ReactiveAdapterRegistry$ReactorRegistrar.lambda$9()Ljava/lang/Object; (6)
                  ()Ljava/lang/Object;
            invokestatic org.springframework.core.ReactiveTypeDescriptor.singleOptionalValue:(Ljava/lang/Class;Ljava/util/function/Supplier;)Lorg/springframework/core/ReactiveTypeDescriptor;
        17: .line 208
            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$ReactorRegistrar.lambda$10(Ljava/lang/Object;)Lorg/reactivestreams/Publisher; (6)
                  (Ljava/lang/Object;)Lorg/reactivestreams/Publisher;
        18: .line 209
            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$ReactorRegistrar.lambda$11(Lorg/reactivestreams/Publisher;)Ljava/lang/Object; (6)
                  (Lorg/reactivestreams/Publisher;)Ljava/lang/Object;
        19: .line 202
            invokevirtual org.springframework.core.ReactiveAdapterRegistry.registerReactiveType:(Lorg/springframework/core/ReactiveTypeDescriptor;Ljava/util/function/Function;Ljava/util/function/Function;)V
        20: .line 211
            return
        end local 1 // org.springframework.core.ReactiveAdapterRegistry registry
        end local 0 // org.springframework.core.ReactiveAdapterRegistry$ReactorRegistrar this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   21     0      this  Lorg/springframework/core/ReactiveAdapterRegistry$ReactorRegistrar;
            0   21     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 188
            aload 0 /* source */
            checkcast reactor.core.publisher.Mono
            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=1, locals=1, args_size=1
        start local 0 // java.lang.Object source
         0: .line 194
            aload 0 /* source */
            checkcast reactor.core.publisher.Flux
            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$7(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 199
            aload 0 /* source */
            checkcast org.reactivestreams.Publisher
            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$8(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 200
            aload 0 /* source */
            areturn
        end local 0 // org.reactivestreams.Publisher source
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0  source  Lorg/reactivestreams/Publisher<*>;

  private static java.lang.Object lambda$9();
    descriptor: ()Ljava/lang/Object;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=0
         0: .line 204
            new java.util.concurrent.CompletableFuture
            dup
            invokespecial java.util.concurrent.CompletableFuture.<init>:()V
            astore 0 /* empty */
        start local 0 // java.util.concurrent.CompletableFuture empty
         1: .line 205
            aload 0 /* empty */
            aconst_null
            invokevirtual java.util.concurrent.CompletableFuture.complete:(Ljava/lang/Object;)Z
            pop
         2: .line 206
            aload 0 /* empty */
            areturn
        end local 0 // java.util.concurrent.CompletableFuture empty
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            1    3     0  empty  Ljava/util/concurrent/CompletableFuture<*>;

  private static org.reactivestreams.Publisher lambda$10(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 208
            aload 0 /* source */
            checkcast java.util.concurrent.CompletableFuture
            invokestatic reactor.core.publisher.Mono.fromFuture:(Ljava/util/concurrent/CompletableFuture;)Lreactor/core/publisher/Mono;
            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$11(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 209
            aload 0 /* source */
            invokestatic reactor.core.publisher.Mono.from:(Lorg/reactivestreams/Publisher;)Lreactor/core/publisher/Mono;
            invokevirtual reactor.core.publisher.Mono.toFuture:()Ljava/util/concurrent/CompletableFuture;
            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 ReactorRegistrar = org.springframework.core.ReactiveAdapterRegistry$ReactorRegistrar of org.springframework.core.ReactiveAdapterRegistry