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

  void registerAdapter(org.springframework.core.ReactiveAdapterRegistry);
    descriptor: (Lorg/springframework/core/ReactiveAdapterRegistry;)V
    flags: (0x0000) 
    Code:
      stack=6, locals=9, args_size=2
        start local 0 // org.springframework.core.ReactiveAdapterRegistry$ReactorJdkFlowAdapterRegistrar this
        start local 1 // org.springframework.core.ReactiveAdapterRegistry registry
         0: .line 275
            ldc "java.util.concurrent.Flow.Publisher"
            astore 2 /* publisherName */
        start local 2 // java.lang.String publisherName
         1: .line 276
            aload 2 /* publisherName */
            aload 0 /* this */
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            invokevirtual java.lang.Class.getClassLoader:()Ljava/lang/ClassLoader;
            invokestatic org.springframework.util.ClassUtils.forName:(Ljava/lang/String;Ljava/lang/ClassLoader;)Ljava/lang/Class;
            astore 3 /* publisherClass */
        start local 3 // java.lang.Class publisherClass
         2: .line 278
            ldc "reactor.adapter.JdkFlowAdapter"
            astore 4 /* adapterName */
        start local 4 // java.lang.String adapterName
         3: .line 279
            aload 4 /* adapterName */
            aload 0 /* this */
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            invokevirtual java.lang.Class.getClassLoader:()Ljava/lang/ClassLoader;
            invokestatic org.springframework.util.ClassUtils.forName:(Ljava/lang/String;Ljava/lang/ClassLoader;)Ljava/lang/Class;
            astore 5 /* flowAdapterClass */
        start local 5 // java.lang.Class flowAdapterClass
         4: .line 281
            aload 5 /* flowAdapterClass */
            ldc "flowPublisherToFlux"
            iconst_1
            anewarray java.lang.Class
            dup
            iconst_0
            aload 3 /* publisherClass */
            aastore
            invokevirtual java.lang.Class.getMethod:(Ljava/lang/String;[Ljava/lang/Class;)Ljava/lang/reflect/Method;
            astore 6 /* toFluxMethod */
        start local 6 // java.lang.reflect.Method toFluxMethod
         5: .line 282
            aload 5 /* flowAdapterClass */
            ldc "publisherToFlowPublisher"
            iconst_1
            anewarray java.lang.Class
            dup
            iconst_0
            ldc Lorg/reactivestreams/Publisher;
            aastore
            invokevirtual java.lang.Class.getMethod:(Ljava/lang/String;[Ljava/lang/Class;)Ljava/lang/reflect/Method;
            astore 7 /* toFlowMethod */
        start local 7 // java.lang.reflect.Method toFlowMethod
         6: .line 283
            aload 7 /* toFlowMethod */
            aconst_null
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            invokestatic reactor.core.publisher.Flux.empty:()Lreactor/core/publisher/Flux;
            aastore
            invokestatic org.springframework.util.ReflectionUtils.invokeMethod:(Ljava/lang/reflect/Method;Ljava/lang/Object;[Ljava/lang/Object;)Ljava/lang/Object;
            astore 8 /* emptyFlow */
        start local 8 // java.lang.Object emptyFlow
         7: .line 285
            aload 1 /* registry */
         8: .line 286
            aload 3 /* publisherClass */
            aload 8 /* emptyFlow */
            invokedynamic get(Ljava/lang/Object;)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$ReactorJdkFlowAdapterRegistrar.lambda$0(Ljava/lang/Object;)Ljava/lang/Object; (6)
                  ()Ljava/lang/Object;
            invokestatic org.springframework.core.ReactiveTypeDescriptor.multiValue:(Ljava/lang/Class;Ljava/util/function/Supplier;)Lorg/springframework/core/ReactiveTypeDescriptor;
         9: .line 287
            aload 6 /* toFluxMethod */
            invokedynamic apply(Ljava/lang/reflect/Method;)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$ReactorJdkFlowAdapterRegistrar.lambda$1(Ljava/lang/reflect/Method;Ljava/lang/Object;)Lorg/reactivestreams/Publisher; (6)
                  (Ljava/lang/Object;)Lorg/reactivestreams/Publisher;
        10: .line 288
            aload 7 /* toFlowMethod */
            invokedynamic apply(Ljava/lang/reflect/Method;)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$ReactorJdkFlowAdapterRegistrar.lambda$2(Ljava/lang/reflect/Method;Lorg/reactivestreams/Publisher;)Ljava/lang/Object; (6)
                  (Lorg/reactivestreams/Publisher;)Ljava/lang/Object;
        11: .line 285
            invokevirtual org.springframework.core.ReactiveAdapterRegistry.registerReactiveType:(Lorg/springframework/core/ReactiveTypeDescriptor;Ljava/util/function/Function;Ljava/util/function/Function;)V
        end local 8 // java.lang.Object emptyFlow
        end local 7 // java.lang.reflect.Method toFlowMethod
        end local 6 // java.lang.reflect.Method toFluxMethod
        end local 5 // java.lang.Class flowAdapterClass
        end local 4 // java.lang.String adapterName
        end local 3 // java.lang.Class publisherClass
        end local 2 // java.lang.String publisherName
        12: .line 290
            goto 14
        13: .line 291
      StackMap locals:
      StackMap stack: java.lang.Throwable
            pop
        14: .line 294
      StackMap locals:
      StackMap stack:
            return
        end local 1 // org.springframework.core.ReactiveAdapterRegistry registry
        end local 0 // org.springframework.core.ReactiveAdapterRegistry$ReactorJdkFlowAdapterRegistrar this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0   15     0              this  Lorg/springframework/core/ReactiveAdapterRegistry$ReactorJdkFlowAdapterRegistrar;
            0   15     1          registry  Lorg/springframework/core/ReactiveAdapterRegistry;
            1   12     2     publisherName  Ljava/lang/String;
            2   12     3    publisherClass  Ljava/lang/Class<*>;
            3   12     4       adapterName  Ljava/lang/String;
            4   12     5  flowAdapterClass  Ljava/lang/Class<*>;
            5   12     6      toFluxMethod  Ljava/lang/reflect/Method;
            6   12     7      toFlowMethod  Ljava/lang/reflect/Method;
            7   12     8         emptyFlow  Ljava/lang/Object;
      Exception table:
        from    to  target  type
           0    12      13  Class java.lang.Throwable
    MethodParameters:
          Name  Flags
      registry  

  private static java.lang.Object lambda$0(java.lang.Object);
    descriptor: (Ljava/lang/Object;)Ljava/lang/Object;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
         0: .line 286
            aload 0
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  private static org.reactivestreams.Publisher lambda$1(java.lang.reflect.Method, java.lang.Object);
    descriptor: (Ljava/lang/reflect/Method;Ljava/lang/Object;)Lorg/reactivestreams/Publisher;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=6, locals=2, args_size=2
        start local 1 // java.lang.Object source
         0: .line 287
            aload 0
            aconst_null
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 1 /* source */
            aastore
            invokestatic org.springframework.util.ReflectionUtils.invokeMethod:(Ljava/lang/reflect/Method;Ljava/lang/Object;[Ljava/lang/Object;)Ljava/lang/Object;
            checkcast org.reactivestreams.Publisher
            areturn
        end local 1 // java.lang.Object source
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     1  source  Ljava/lang/Object;

  private static java.lang.Object lambda$2(java.lang.reflect.Method, org.reactivestreams.Publisher);
    descriptor: (Ljava/lang/reflect/Method;Lorg/reactivestreams/Publisher;)Ljava/lang/Object;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=6, locals=2, args_size=2
        start local 1 // org.reactivestreams.Publisher publisher
         0: .line 288
            aload 0
            aconst_null
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 1 /* publisher */
            aastore
            invokestatic org.springframework.util.ReflectionUtils.invokeMethod:(Ljava/lang/reflect/Method;Ljava/lang/Object;[Ljava/lang/Object;)Ljava/lang/Object;
            areturn
        end local 1 // org.reactivestreams.Publisher publisher
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    1     1  publisher  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 ReactorJdkFlowAdapterRegistrar = org.springframework.core.ReactiveAdapterRegistry$ReactorJdkFlowAdapterRegistrar of org.springframework.core.ReactiveAdapterRegistry