class org.springframework.http.client.reactive.ReactorClientHttpRequest extends org.springframework.http.client.reactive.AbstractClientHttpRequest implements org.springframework.http.ZeroCopyHttpOutputMessage
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: org.springframework.http.client.reactive.ReactorClientHttpRequest
  super_class: org.springframework.http.client.reactive.AbstractClientHttpRequest
{
  private final org.springframework.http.HttpMethod httpMethod;
    descriptor: Lorg/springframework/http/HttpMethod;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.net.URI uri;
    descriptor: Ljava/net/URI;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final reactor.netty.http.client.HttpClientRequest request;
    descriptor: Lreactor/netty/http/client/HttpClientRequest;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final reactor.netty.NettyOutbound outbound;
    descriptor: Lreactor/netty/NettyOutbound;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final org.springframework.core.io.buffer.NettyDataBufferFactory bufferFactory;
    descriptor: Lorg/springframework/core/io/buffer/NettyDataBufferFactory;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  public void <init>(org.springframework.http.HttpMethod, java.net.URI, reactor.netty.http.client.HttpClientRequest, reactor.netty.NettyOutbound);
    descriptor: (Lorg/springframework/http/HttpMethod;Ljava/net/URI;Lreactor/netty/http/client/HttpClientRequest;Lreactor/netty/NettyOutbound;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=5, args_size=5
        start local 0 // org.springframework.http.client.reactive.ReactorClientHttpRequest this
        start local 1 // org.springframework.http.HttpMethod method
        start local 2 // java.net.URI uri
        start local 3 // reactor.netty.http.client.HttpClientRequest request
        start local 4 // reactor.netty.NettyOutbound outbound
         0: .line 57
            aload 0 /* this */
            invokespecial org.springframework.http.client.reactive.AbstractClientHttpRequest.<init>:()V
         1: .line 58
            aload 0 /* this */
            aload 1 /* method */
            putfield org.springframework.http.client.reactive.ReactorClientHttpRequest.httpMethod:Lorg/springframework/http/HttpMethod;
         2: .line 59
            aload 0 /* this */
            aload 2 /* uri */
            putfield org.springframework.http.client.reactive.ReactorClientHttpRequest.uri:Ljava/net/URI;
         3: .line 60
            aload 0 /* this */
            aload 3 /* request */
            putfield org.springframework.http.client.reactive.ReactorClientHttpRequest.request:Lreactor/netty/http/client/HttpClientRequest;
         4: .line 61
            aload 0 /* this */
            aload 4 /* outbound */
            putfield org.springframework.http.client.reactive.ReactorClientHttpRequest.outbound:Lreactor/netty/NettyOutbound;
         5: .line 62
            aload 0 /* this */
            new org.springframework.core.io.buffer.NettyDataBufferFactory
            dup
            aload 4 /* outbound */
            invokeinterface reactor.netty.NettyOutbound.alloc:()Lio/netty/buffer/ByteBufAllocator;
            invokespecial org.springframework.core.io.buffer.NettyDataBufferFactory.<init>:(Lio/netty/buffer/ByteBufAllocator;)V
            putfield org.springframework.http.client.reactive.ReactorClientHttpRequest.bufferFactory:Lorg/springframework/core/io/buffer/NettyDataBufferFactory;
         6: .line 63
            return
        end local 4 // reactor.netty.NettyOutbound outbound
        end local 3 // reactor.netty.http.client.HttpClientRequest request
        end local 2 // java.net.URI uri
        end local 1 // org.springframework.http.HttpMethod method
        end local 0 // org.springframework.http.client.reactive.ReactorClientHttpRequest this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    7     0      this  Lorg/springframework/http/client/reactive/ReactorClientHttpRequest;
            0    7     1    method  Lorg/springframework/http/HttpMethod;
            0    7     2       uri  Ljava/net/URI;
            0    7     3   request  Lreactor/netty/http/client/HttpClientRequest;
            0    7     4  outbound  Lreactor/netty/NettyOutbound;
    MethodParameters:
          Name  Flags
      method    
      uri       
      request   
      outbound  

  public org.springframework.core.io.buffer.DataBufferFactory bufferFactory();
    descriptor: ()Lorg/springframework/core/io/buffer/DataBufferFactory;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.springframework.http.client.reactive.ReactorClientHttpRequest this
         0: .line 68
            aload 0 /* this */
            getfield org.springframework.http.client.reactive.ReactorClientHttpRequest.bufferFactory:Lorg/springframework/core/io/buffer/NettyDataBufferFactory;
            areturn
        end local 0 // org.springframework.http.client.reactive.ReactorClientHttpRequest this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/springframework/http/client/reactive/ReactorClientHttpRequest;

  public org.springframework.http.HttpMethod getMethod();
    descriptor: ()Lorg/springframework/http/HttpMethod;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.springframework.http.client.reactive.ReactorClientHttpRequest this
         0: .line 73
            aload 0 /* this */
            getfield org.springframework.http.client.reactive.ReactorClientHttpRequest.httpMethod:Lorg/springframework/http/HttpMethod;
            areturn
        end local 0 // org.springframework.http.client.reactive.ReactorClientHttpRequest this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/springframework/http/client/reactive/ReactorClientHttpRequest;

  public java.net.URI getURI();
    descriptor: ()Ljava/net/URI;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.springframework.http.client.reactive.ReactorClientHttpRequest this
         0: .line 78
            aload 0 /* this */
            getfield org.springframework.http.client.reactive.ReactorClientHttpRequest.uri:Ljava/net/URI;
            areturn
        end local 0 // org.springframework.http.client.reactive.ReactorClientHttpRequest this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/springframework/http/client/reactive/ReactorClientHttpRequest;

  public reactor.core.publisher.Mono<java.lang.Void> writeWith(org.reactivestreams.Publisher<? extends org.springframework.core.io.buffer.DataBuffer>);
    descriptor: (Lorg/reactivestreams/Publisher;)Lreactor/core/publisher/Mono;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // org.springframework.http.client.reactive.ReactorClientHttpRequest this
        start local 1 // org.reactivestreams.Publisher body
         0: .line 83
            aload 0 /* this */
            aload 0 /* this */
            aload 1 /* body */
            invokedynamic get(Lorg/springframework/http/client/reactive/ReactorClientHttpRequest;Lorg/reactivestreams/Publisher;)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/http/client/reactive/ReactorClientHttpRequest.lambda$0(Lorg/reactivestreams/Publisher;)Lorg/reactivestreams/Publisher; (7)
                  ()Lorg/reactivestreams/Publisher;
            invokevirtual org.springframework.http.client.reactive.ReactorClientHttpRequest.doCommit:(Ljava/util/function/Supplier;)Lreactor/core/publisher/Mono;
            areturn
        end local 1 // org.reactivestreams.Publisher body
        end local 0 // org.springframework.http.client.reactive.ReactorClientHttpRequest this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/springframework/http/client/reactive/ReactorClientHttpRequest;
            0    1     1  body  Lorg/reactivestreams/Publisher<+Lorg/springframework/core/io/buffer/DataBuffer;>;
    Signature: (Lorg/reactivestreams/Publisher<+Lorg/springframework/core/io/buffer/DataBuffer;>;)Lreactor/core/publisher/Mono<Ljava/lang/Void;>;
    MethodParameters:
      Name  Flags
      body  

  public reactor.core.publisher.Mono<java.lang.Void> writeAndFlushWith(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends org.springframework.core.io.buffer.DataBuffer>>);
    descriptor: (Lorg/reactivestreams/Publisher;)Lreactor/core/publisher/Mono;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // org.springframework.http.client.reactive.ReactorClientHttpRequest this
        start local 1 // org.reactivestreams.Publisher body
         0: .line 91
            aload 1 /* body */
            invokestatic reactor.core.publisher.Flux.from:(Lorg/reactivestreams/Publisher;)Lreactor/core/publisher/Flux;
            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/http/client/reactive/ReactorClientHttpRequest.toByteBufs(Lorg/reactivestreams/Publisher;)Lorg/reactivestreams/Publisher; (6)
                  (Lorg/reactivestreams/Publisher;)Lorg/reactivestreams/Publisher;
            invokevirtual reactor.core.publisher.Flux.map:(Ljava/util/function/Function;)Lreactor/core/publisher/Flux;
            astore 2 /* byteBufs */
        start local 2 // org.reactivestreams.Publisher byteBufs
         1: .line 92
            aload 0 /* this */
            aload 0 /* this */
            aload 2 /* byteBufs */
            invokedynamic get(Lorg/springframework/http/client/reactive/ReactorClientHttpRequest;Lorg/reactivestreams/Publisher;)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/http/client/reactive/ReactorClientHttpRequest.lambda$3(Lorg/reactivestreams/Publisher;)Lorg/reactivestreams/Publisher; (7)
                  ()Lorg/reactivestreams/Publisher;
            invokevirtual org.springframework.http.client.reactive.ReactorClientHttpRequest.doCommit:(Ljava/util/function/Supplier;)Lreactor/core/publisher/Mono;
            areturn
        end local 2 // org.reactivestreams.Publisher byteBufs
        end local 1 // org.reactivestreams.Publisher body
        end local 0 // org.springframework.http.client.reactive.ReactorClientHttpRequest this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0      this  Lorg/springframework/http/client/reactive/ReactorClientHttpRequest;
            0    2     1      body  Lorg/reactivestreams/Publisher<+Lorg/reactivestreams/Publisher<+Lorg/springframework/core/io/buffer/DataBuffer;>;>;
            1    2     2  byteBufs  Lorg/reactivestreams/Publisher<Lorg/reactivestreams/Publisher<Lio/netty/buffer/ByteBuf;>;>;
    Signature: (Lorg/reactivestreams/Publisher<+Lorg/reactivestreams/Publisher<+Lorg/springframework/core/io/buffer/DataBuffer;>;>;)Lreactor/core/publisher/Mono<Ljava/lang/Void;>;
    MethodParameters:
      Name  Flags
      body  

  private static org.reactivestreams.Publisher<io.netty.buffer.ByteBuf> toByteBufs(org.reactivestreams.Publisher<? extends org.springframework.core.io.buffer.DataBuffer>);
    descriptor: (Lorg/reactivestreams/Publisher;)Lorg/reactivestreams/Publisher;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.reactivestreams.Publisher dataBuffers
         0: .line 96
            aload 0 /* dataBuffers */
            invokestatic reactor.core.publisher.Flux.from:(Lorg/reactivestreams/Publisher;)Lreactor/core/publisher/Flux;
            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/io/buffer/NettyDataBufferFactory.toByteBuf(Lorg/springframework/core/io/buffer/DataBuffer;)Lio/netty/buffer/ByteBuf; (6)
                  (Lorg/springframework/core/io/buffer/DataBuffer;)Lio/netty/buffer/ByteBuf;
            invokevirtual reactor.core.publisher.Flux.map:(Ljava/util/function/Function;)Lreactor/core/publisher/Flux;
            areturn
        end local 0 // org.reactivestreams.Publisher dataBuffers
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    1     0  dataBuffers  Lorg/reactivestreams/Publisher<+Lorg/springframework/core/io/buffer/DataBuffer;>;
    Signature: (Lorg/reactivestreams/Publisher<+Lorg/springframework/core/io/buffer/DataBuffer;>;)Lorg/reactivestreams/Publisher<Lio/netty/buffer/ByteBuf;>;
    MethodParameters:
             Name  Flags
      dataBuffers  

  public reactor.core.publisher.Mono<java.lang.Void> writeWith(java.nio.file.Path, long, long);
    descriptor: (Ljava/nio/file/Path;JJ)Lreactor/core/publisher/Mono;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=6, args_size=4
        start local 0 // org.springframework.http.client.reactive.ReactorClientHttpRequest this
        start local 1 // java.nio.file.Path file
        start local 2 // long position
        start local 4 // long count
         0: .line 101
            aload 0 /* this */
            aload 0 /* this */
            aload 1 /* file */
            lload 2 /* position */
            lload 4 /* count */
            invokedynamic get(Lorg/springframework/http/client/reactive/ReactorClientHttpRequest;Ljava/nio/file/Path;JJ)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/http/client/reactive/ReactorClientHttpRequest.lambda$5(Ljava/nio/file/Path;JJ)Lorg/reactivestreams/Publisher; (7)
                  ()Lorg/reactivestreams/Publisher;
            invokevirtual org.springframework.http.client.reactive.ReactorClientHttpRequest.doCommit:(Ljava/util/function/Supplier;)Lreactor/core/publisher/Mono;
            areturn
        end local 4 // long count
        end local 2 // long position
        end local 1 // java.nio.file.Path file
        end local 0 // org.springframework.http.client.reactive.ReactorClientHttpRequest this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    1     0      this  Lorg/springframework/http/client/reactive/ReactorClientHttpRequest;
            0    1     1      file  Ljava/nio/file/Path;
            0    1     2  position  J
            0    1     4     count  J
    Signature: (Ljava/nio/file/Path;JJ)Lreactor/core/publisher/Mono<Ljava/lang/Void;>;
    MethodParameters:
          Name  Flags
      file      
      position  
      count     

  public reactor.core.publisher.Mono<java.lang.Void> setComplete();
    descriptor: ()Lreactor/core/publisher/Mono;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // org.springframework.http.client.reactive.ReactorClientHttpRequest this
         0: .line 106
            aload 0 /* this */
            aload 0 /* this */
            getfield org.springframework.http.client.reactive.ReactorClientHttpRequest.outbound:Lreactor/netty/NettyOutbound;
            dup
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            pop
            invokedynamic get(Lreactor/netty/NettyOutbound;)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/netty/NettyOutbound.then()Lreactor/core/publisher/Mono; (9 itf)
                  ()Lorg/reactivestreams/Publisher;
            invokevirtual org.springframework.http.client.reactive.ReactorClientHttpRequest.doCommit:(Ljava/util/function/Supplier;)Lreactor/core/publisher/Mono;
            areturn
        end local 0 // org.springframework.http.client.reactive.ReactorClientHttpRequest this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/springframework/http/client/reactive/ReactorClientHttpRequest;
    Signature: ()Lreactor/core/publisher/Mono<Ljava/lang/Void;>;

  protected void applyHeaders();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.springframework.http.client.reactive.ReactorClientHttpRequest this
         0: .line 111
            aload 0 /* this */
            invokevirtual org.springframework.http.client.reactive.ReactorClientHttpRequest.getHeaders:()Lorg/springframework/http/HttpHeaders;
            aload 0 /* this */
            invokedynamic accept(Lorg/springframework/http/client/reactive/ReactorClientHttpRequest;)Ljava/util/function/BiConsumer;
              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;)V
                  org/springframework/http/client/reactive/ReactorClientHttpRequest.lambda$7(Ljava/lang/String;Ljava/util/List;)V (7)
                  (Ljava/lang/String;Ljava/util/List;)V
            invokevirtual org.springframework.http.HttpHeaders.forEach:(Ljava/util/function/BiConsumer;)V
         1: .line 112
            return
        end local 0 // org.springframework.http.client.reactive.ReactorClientHttpRequest this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/springframework/http/client/reactive/ReactorClientHttpRequest;

  protected void applyCookies();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // org.springframework.http.client.reactive.ReactorClientHttpRequest this
         0: .line 116
            aload 0 /* this */
            invokevirtual org.springframework.http.client.reactive.ReactorClientHttpRequest.getCookies:()Lorg/springframework/util/MultiValueMap;
            invokeinterface org.springframework.util.MultiValueMap.values:()Ljava/util/Collection;
            invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
            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;
                  java/util/Collection.stream()Ljava/util/stream/Stream; (9 itf)
                  (Ljava/util/List;)Ljava/util/stream/Stream;
            invokeinterface java.util.stream.Stream.flatMap:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
         1: .line 117
            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/http/client/reactive/ReactorClientHttpRequest.lambda$9(Lorg/springframework/http/HttpCookie;)Lio/netty/handler/codec/http/cookie/DefaultCookie; (6)
                  (Lorg/springframework/http/HttpCookie;)Lio/netty/handler/codec/http/cookie/DefaultCookie;
            invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
         2: .line 118
            aload 0 /* this */
            getfield org.springframework.http.client.reactive.ReactorClientHttpRequest.request:Lreactor/netty/http/client/HttpClientRequest;
            dup
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            pop
            invokedynamic accept(Lreactor/netty/http/client/HttpClientRequest;)Ljava/util/function/Consumer;
              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;)V
                  reactor/netty/http/client/HttpClientRequest.addCookie(Lio/netty/handler/codec/http/cookie/Cookie;)Lreactor/netty/http/client/HttpClientRequest; (9 itf)
                  (Lio/netty/handler/codec/http/cookie/DefaultCookie;)V
            invokeinterface java.util.stream.Stream.forEach:(Ljava/util/function/Consumer;)V
         3: .line 119
            return
        end local 0 // org.springframework.http.client.reactive.ReactorClientHttpRequest this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lorg/springframework/http/client/reactive/ReactorClientHttpRequest;

  private org.reactivestreams.Publisher lambda$0(org.reactivestreams.Publisher);
    descriptor: (Lorg/reactivestreams/Publisher;)Lorg/reactivestreams/Publisher;
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // org.springframework.http.client.reactive.ReactorClientHttpRequest this
         0: .line 84
            aload 1
            invokestatic reactor.core.publisher.Flux.from:(Lorg/reactivestreams/Publisher;)Lreactor/core/publisher/Flux;
            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/io/buffer/NettyDataBufferFactory.toByteBuf(Lorg/springframework/core/io/buffer/DataBuffer;)Lio/netty/buffer/ByteBuf; (6)
                  (Lorg/springframework/core/io/buffer/DataBuffer;)Lio/netty/buffer/ByteBuf;
            invokevirtual reactor.core.publisher.Flux.map:(Ljava/util/function/Function;)Lreactor/core/publisher/Flux;
            astore 2 /* byteBufFlux */
        start local 2 // reactor.core.publisher.Flux byteBufFlux
         1: .line 85
            aload 0 /* this */
            getfield org.springframework.http.client.reactive.ReactorClientHttpRequest.outbound:Lreactor/netty/NettyOutbound;
            aload 2 /* byteBufFlux */
            invokeinterface reactor.netty.NettyOutbound.send:(Lorg/reactivestreams/Publisher;)Lreactor/netty/NettyOutbound;
            invokeinterface reactor.netty.NettyOutbound.then:()Lreactor/core/publisher/Mono;
            areturn
        end local 2 // reactor.core.publisher.Flux byteBufFlux
        end local 0 // org.springframework.http.client.reactive.ReactorClientHttpRequest this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    2     0         this  Lorg/springframework/http/client/reactive/ReactorClientHttpRequest;
            1    2     2  byteBufFlux  Lreactor/core/publisher/Flux<Lio/netty/buffer/ByteBuf;>;

  private org.reactivestreams.Publisher lambda$3(org.reactivestreams.Publisher);
    descriptor: (Lorg/reactivestreams/Publisher;)Lorg/reactivestreams/Publisher;
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.springframework.http.client.reactive.ReactorClientHttpRequest this
         0: .line 92
            aload 0 /* this */
            getfield org.springframework.http.client.reactive.ReactorClientHttpRequest.outbound:Lreactor/netty/NettyOutbound;
            aload 1
            invokeinterface reactor.netty.NettyOutbound.sendGroups:(Lorg/reactivestreams/Publisher;)Lreactor/netty/NettyOutbound;
            invokeinterface reactor.netty.NettyOutbound.then:()Lreactor/core/publisher/Mono;
            areturn
        end local 0 // org.springframework.http.client.reactive.ReactorClientHttpRequest this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/springframework/http/client/reactive/ReactorClientHttpRequest;

  private org.reactivestreams.Publisher lambda$5(java.nio.file.Path, long, long);
    descriptor: (Ljava/nio/file/Path;JJ)Lorg/reactivestreams/Publisher;
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=6, locals=6, args_size=4
        start local 0 // org.springframework.http.client.reactive.ReactorClientHttpRequest this
         0: .line 101
            aload 0 /* this */
            getfield org.springframework.http.client.reactive.ReactorClientHttpRequest.outbound:Lreactor/netty/NettyOutbound;
            aload 1
            lload 2
            lload 4
            invokeinterface reactor.netty.NettyOutbound.sendFile:(Ljava/nio/file/Path;JJ)Lreactor/netty/NettyOutbound;
            invokeinterface reactor.netty.NettyOutbound.then:()Lreactor/core/publisher/Mono;
            areturn
        end local 0 // org.springframework.http.client.reactive.ReactorClientHttpRequest this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/springframework/http/client/reactive/ReactorClientHttpRequest;

  private void lambda$7(java.lang.String, java.util.List);
    descriptor: (Ljava/lang/String;Ljava/util/List;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // org.springframework.http.client.reactive.ReactorClientHttpRequest this
        start local 1 // java.lang.String key
        start local 2 // java.util.List value
         0: .line 111
            aload 0 /* this */
            getfield org.springframework.http.client.reactive.ReactorClientHttpRequest.request:Lreactor/netty/http/client/HttpClientRequest;
            invokeinterface reactor.netty.http.client.HttpClientRequest.requestHeaders:()Lio/netty/handler/codec/http/HttpHeaders;
            aload 1 /* key */
            aload 2 /* value */
            invokevirtual io.netty.handler.codec.http.HttpHeaders.set:(Ljava/lang/String;Ljava/lang/Iterable;)Lio/netty/handler/codec/http/HttpHeaders;
            return
        end local 2 // java.util.List value
        end local 1 // java.lang.String key
        end local 0 // org.springframework.http.client.reactive.ReactorClientHttpRequest this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    1     0   this  Lorg/springframework/http/client/reactive/ReactorClientHttpRequest;
            0    1     1    key  Ljava/lang/String;
            0    1     2  value  Ljava/util/List<Ljava/lang/String;>;

  private static io.netty.handler.codec.http.cookie.DefaultCookie lambda$9(org.springframework.http.HttpCookie);
    descriptor: (Lorg/springframework/http/HttpCookie;)Lio/netty/handler/codec/http/cookie/DefaultCookie;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // org.springframework.http.HttpCookie cookie
         0: .line 117
            new io.netty.handler.codec.http.cookie.DefaultCookie
            dup
            aload 0 /* cookie */
            invokevirtual org.springframework.http.HttpCookie.getName:()Ljava/lang/String;
            aload 0 /* cookie */
            invokevirtual org.springframework.http.HttpCookie.getValue:()Ljava/lang/String;
            invokespecial io.netty.handler.codec.http.cookie.DefaultCookie.<init>:(Ljava/lang/String;Ljava/lang/String;)V
            areturn
        end local 0 // org.springframework.http.HttpCookie cookie
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0  cookie  Lorg/springframework/http/HttpCookie;
}
SourceFile: "ReactorClientHttpRequest.java"
InnerClasses:
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles