https://github.com/spring-projects/spring-framework: Spring Web (Spring IO)
  • Juergen Hoeller 
public class org.springframework.http.client.reactive.JettyClientHttpConnector implements org.springframework.http.client.reactive.ClientHttpConnector
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.springframework.http.client.reactive.JettyClientHttpConnector
  super_class: java.lang.Object
{
  private final org.eclipse.jetty.client.HttpClient httpClient;
    descriptor: Lorg/eclipse/jetty/client/HttpClient;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private org.springframework.core.io.buffer.DataBufferFactory bufferFactory;
    descriptor: Lorg/springframework/core/io/buffer/DataBufferFactory;
    flags: (0x0002) ACC_PRIVATE

  public void <init>();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // org.springframework.http.client.reactive.JettyClientHttpConnector this
         0: .line 53
            aload 0 /* this */
            new org.eclipse.jetty.client.HttpClient
            dup
            invokespecial org.eclipse.jetty.client.HttpClient.<init>:()V
            invokespecial org.springframework.http.client.reactive.JettyClientHttpConnector.<init>:(Lorg/eclipse/jetty/client/HttpClient;)V
         1: .line 54
            return
        end local 0 // org.springframework.http.client.reactive.JettyClientHttpConnector this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/springframework/http/client/reactive/JettyClientHttpConnector;

  public void <init>(org.springframework.http.client.reactive.JettyResourceFactory, java.util.function.Consumer<org.eclipse.jetty.client.HttpClient>);
    descriptor: (Lorg/springframework/http/client/reactive/JettyResourceFactory;Ljava/util/function/Consumer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=4, args_size=3
        start local 0 // org.springframework.http.client.reactive.JettyClientHttpConnector this
        start local 1 // org.springframework.http.client.reactive.JettyResourceFactory resourceFactory
        start local 2 // java.util.function.Consumer customizer
         0: .line 61
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 46
            aload 0 /* this */
            new org.springframework.core.io.buffer.DefaultDataBufferFactory
            dup
            invokespecial org.springframework.core.io.buffer.DefaultDataBufferFactory.<init>:()V
            putfield org.springframework.http.client.reactive.JettyClientHttpConnector.bufferFactory:Lorg/springframework/core/io/buffer/DataBufferFactory;
         2: .line 64
            new org.eclipse.jetty.client.HttpClient
            dup
            invokespecial org.eclipse.jetty.client.HttpClient.<init>:()V
            astore 3 /* httpClient */
        start local 3 // org.eclipse.jetty.client.HttpClient httpClient
         3: .line 65
            aload 3 /* httpClient */
            aload 1 /* resourceFactory */
            invokevirtual org.springframework.http.client.reactive.JettyResourceFactory.getExecutor:()Ljava/util/concurrent/Executor;
            invokevirtual org.eclipse.jetty.client.HttpClient.setExecutor:(Ljava/util/concurrent/Executor;)V
         4: .line 66
            aload 3 /* httpClient */
            aload 1 /* resourceFactory */
            invokevirtual org.springframework.http.client.reactive.JettyResourceFactory.getByteBufferPool:()Lorg/eclipse/jetty/io/ByteBufferPool;
            invokevirtual org.eclipse.jetty.client.HttpClient.setByteBufferPool:(Lorg/eclipse/jetty/io/ByteBufferPool;)V
         5: .line 67
            aload 3 /* httpClient */
            aload 1 /* resourceFactory */
            invokevirtual org.springframework.http.client.reactive.JettyResourceFactory.getScheduler:()Lorg/eclipse/jetty/util/thread/Scheduler;
            invokevirtual org.eclipse.jetty.client.HttpClient.setScheduler:(Lorg/eclipse/jetty/util/thread/Scheduler;)V
         6: .line 68
            aload 2 /* customizer */
            ifnull 8
         7: .line 69
            aload 2 /* customizer */
            aload 3 /* httpClient */
            invokeinterface java.util.function.Consumer.accept:(Ljava/lang/Object;)V
         8: .line 71
      StackMap locals: org.springframework.http.client.reactive.JettyClientHttpConnector org.springframework.http.client.reactive.JettyResourceFactory java.util.function.Consumer org.eclipse.jetty.client.HttpClient
      StackMap stack:
            aload 0 /* this */
            aload 3 /* httpClient */
            putfield org.springframework.http.client.reactive.JettyClientHttpConnector.httpClient:Lorg/eclipse/jetty/client/HttpClient;
         9: .line 72
            return
        end local 3 // org.eclipse.jetty.client.HttpClient httpClient
        end local 2 // java.util.function.Consumer customizer
        end local 1 // org.springframework.http.client.reactive.JettyResourceFactory resourceFactory
        end local 0 // org.springframework.http.client.reactive.JettyClientHttpConnector this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0   10     0             this  Lorg/springframework/http/client/reactive/JettyClientHttpConnector;
            0   10     1  resourceFactory  Lorg/springframework/http/client/reactive/JettyResourceFactory;
            0   10     2       customizer  Ljava/util/function/Consumer<Lorg/eclipse/jetty/client/HttpClient;>;
            3   10     3       httpClient  Lorg/eclipse/jetty/client/HttpClient;
    Signature: (Lorg/springframework/http/client/reactive/JettyResourceFactory;Ljava/util/function/Consumer<Lorg/eclipse/jetty/client/HttpClient;>;)V
    RuntimeVisibleParameterAnnotations: 
      0:
      1:
        org.springframework.lang.Nullable()
    MethodParameters:
                 Name  Flags
      resourceFactory  
      customizer       

  public void <init>(org.eclipse.jetty.client.HttpClient);
    descriptor: (Lorg/eclipse/jetty/client/HttpClient;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // org.springframework.http.client.reactive.JettyClientHttpConnector this
        start local 1 // org.eclipse.jetty.client.HttpClient httpClient
         0: .line 77
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 46
            aload 0 /* this */
            new org.springframework.core.io.buffer.DefaultDataBufferFactory
            dup
            invokespecial org.springframework.core.io.buffer.DefaultDataBufferFactory.<init>:()V
            putfield org.springframework.http.client.reactive.JettyClientHttpConnector.bufferFactory:Lorg/springframework/core/io/buffer/DataBufferFactory;
         2: .line 78
            aload 1 /* httpClient */
            ldc "HttpClient is required"
            invokestatic org.springframework.util.Assert.notNull:(Ljava/lang/Object;Ljava/lang/String;)V
         3: .line 79
            aload 0 /* this */
            aload 1 /* httpClient */
            putfield org.springframework.http.client.reactive.JettyClientHttpConnector.httpClient:Lorg/eclipse/jetty/client/HttpClient;
         4: .line 80
            return
        end local 1 // org.eclipse.jetty.client.HttpClient httpClient
        end local 0 // org.springframework.http.client.reactive.JettyClientHttpConnector this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    5     0        this  Lorg/springframework/http/client/reactive/JettyClientHttpConnector;
            0    5     1  httpClient  Lorg/eclipse/jetty/client/HttpClient;
    MethodParameters:
            Name  Flags
      httpClient  

  public void setBufferFactory(org.springframework.core.io.buffer.DataBufferFactory);
    descriptor: (Lorg/springframework/core/io/buffer/DataBufferFactory;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.springframework.http.client.reactive.JettyClientHttpConnector this
        start local 1 // org.springframework.core.io.buffer.DataBufferFactory bufferFactory
         0: .line 84
            aload 0 /* this */
            aload 1 /* bufferFactory */
            putfield org.springframework.http.client.reactive.JettyClientHttpConnector.bufferFactory:Lorg/springframework/core/io/buffer/DataBufferFactory;
         1: .line 85
            return
        end local 1 // org.springframework.core.io.buffer.DataBufferFactory bufferFactory
        end local 0 // org.springframework.http.client.reactive.JettyClientHttpConnector this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    2     0           this  Lorg/springframework/http/client/reactive/JettyClientHttpConnector;
            0    2     1  bufferFactory  Lorg/springframework/core/io/buffer/DataBufferFactory;
    MethodParameters:
               Name  Flags
      bufferFactory  

  public reactor.core.publisher.Mono<org.springframework.http.client.reactive.ClientHttpResponse> connect(org.springframework.http.HttpMethod, java.net.URI, java.util.function.Function<? super org.springframework.http.client.reactive.ClientHttpRequest, reactor.core.publisher.Mono<java.lang.Void>>);
    descriptor: (Lorg/springframework/http/HttpMethod;Ljava/net/URI;Ljava/util/function/Function;)Lreactor/core/publisher/Mono;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=5, args_size=4
        start local 0 // org.springframework.http.client.reactive.JettyClientHttpConnector this
        start local 1 // org.springframework.http.HttpMethod method
        start local 2 // java.net.URI uri
        start local 3 // java.util.function.Function requestCallback
         0: .line 92
            aload 2 /* uri */
            invokevirtual java.net.URI.isAbsolute:()Z
            ifne 2
         1: .line 93
            new java.lang.IllegalArgumentException
            dup
            new java.lang.StringBuilder
            dup
            ldc "URI is not absolute: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 2 /* uri */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
            invokestatic reactor.core.publisher.Mono.error:(Ljava/lang/Throwable;)Lreactor/core/publisher/Mono;
            areturn
         2: .line 96
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.springframework.http.client.reactive.JettyClientHttpConnector.httpClient:Lorg/eclipse/jetty/client/HttpClient;
            invokevirtual org.eclipse.jetty.client.HttpClient.isStarted:()Z
            ifne 7
         3: .line 98
            aload 0 /* this */
            getfield org.springframework.http.client.reactive.JettyClientHttpConnector.httpClient:Lorg/eclipse/jetty/client/HttpClient;
            invokevirtual org.eclipse.jetty.client.HttpClient.start:()V
         4: .line 99
            goto 7
         5: .line 100
      StackMap locals:
      StackMap stack: java.lang.Exception
            astore 4 /* ex */
        start local 4 // java.lang.Exception ex
         6: .line 101
            aload 4 /* ex */
            invokestatic reactor.core.publisher.Mono.error:(Ljava/lang/Throwable;)Lreactor/core/publisher/Mono;
            areturn
        end local 4 // java.lang.Exception ex
         7: .line 105
      StackMap locals:
      StackMap stack:
            new org.springframework.http.client.reactive.JettyClientHttpRequest
            dup
         8: .line 106
            aload 0 /* this */
            getfield org.springframework.http.client.reactive.JettyClientHttpConnector.httpClient:Lorg/eclipse/jetty/client/HttpClient;
            aload 2 /* uri */
            invokevirtual org.eclipse.jetty.client.HttpClient.newRequest:(Ljava/net/URI;)Lorg/eclipse/jetty/client/api/Request;
            aload 1 /* method */
            invokevirtual org.springframework.http.HttpMethod.toString:()Ljava/lang/String;
            invokeinterface org.eclipse.jetty.client.api.Request.method:(Ljava/lang/String;)Lorg/eclipse/jetty/client/api/Request;
            aload 0 /* this */
            getfield org.springframework.http.client.reactive.JettyClientHttpConnector.bufferFactory:Lorg/springframework/core/io/buffer/DataBufferFactory;
         9: .line 105
            invokespecial org.springframework.http.client.reactive.JettyClientHttpRequest.<init>:(Lorg/eclipse/jetty/client/api/Request;Lorg/springframework/core/io/buffer/DataBufferFactory;)V
            astore 4 /* clientHttpRequest */
        start local 4 // org.springframework.http.client.reactive.JettyClientHttpRequest clientHttpRequest
        10: .line 108
            aload 3 /* requestCallback */
            aload 4 /* clientHttpRequest */
            invokeinterface java.util.function.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast reactor.core.publisher.Mono
        11: .line 109
            aload 4 /* clientHttpRequest */
            invokevirtual org.springframework.http.client.reactive.JettyClientHttpRequest.getReactiveRequest:()Lorg/eclipse/jetty/reactive/client/ReactiveRequest;
            aload 0 /* this */
            invokedynamic apply(Lorg/springframework/http/client/reactive/JettyClientHttpConnector;)Ljava/util/function/BiFunction;
              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;)Ljava/lang/Object;
                  org/springframework/http/client/reactive/JettyClientHttpConnector.lambda$0(Lorg/eclipse/jetty/reactive/client/ReactiveResponse;Lorg/reactivestreams/Publisher;)Lorg/reactivestreams/Publisher; (7)
                  (Lorg/eclipse/jetty/reactive/client/ReactiveResponse;Lorg/reactivestreams/Publisher;)Lorg/reactivestreams/Publisher;
            invokevirtual org.eclipse.jetty.reactive.client.ReactiveRequest.response:(Ljava/util/function/BiFunction;)Lorg/reactivestreams/Publisher;
        12: .line 108
            invokestatic reactor.core.publisher.Mono.from:(Lorg/reactivestreams/Publisher;)Lreactor/core/publisher/Mono;
            invokevirtual reactor.core.publisher.Mono.then:(Lreactor/core/publisher/Mono;)Lreactor/core/publisher/Mono;
            areturn
        end local 4 // org.springframework.http.client.reactive.JettyClientHttpRequest clientHttpRequest
        end local 3 // java.util.function.Function requestCallback
        end local 2 // java.net.URI uri
        end local 1 // org.springframework.http.HttpMethod method
        end local 0 // org.springframework.http.client.reactive.JettyClientHttpConnector this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0   13     0               this  Lorg/springframework/http/client/reactive/JettyClientHttpConnector;
            0   13     1             method  Lorg/springframework/http/HttpMethod;
            0   13     2                uri  Ljava/net/URI;
            0   13     3    requestCallback  Ljava/util/function/Function<-Lorg/springframework/http/client/reactive/ClientHttpRequest;Lreactor/core/publisher/Mono<Ljava/lang/Void;>;>;
            6    7     4                 ex  Ljava/lang/Exception;
           10   13     4  clientHttpRequest  Lorg/springframework/http/client/reactive/JettyClientHttpRequest;
      Exception table:
        from    to  target  type
           3     4       5  Class java.lang.Exception
    Signature: (Lorg/springframework/http/HttpMethod;Ljava/net/URI;Ljava/util/function/Function<-Lorg/springframework/http/client/reactive/ClientHttpRequest;Lreactor/core/publisher/Mono<Ljava/lang/Void;>;>;)Lreactor/core/publisher/Mono<Lorg/springframework/http/client/reactive/ClientHttpResponse;>;
    MethodParameters:
                 Name  Flags
      method           
      uri              
      requestCallback  

  private org.springframework.core.io.buffer.DataBuffer toDataBuffer(org.eclipse.jetty.reactive.client.ContentChunk);
    descriptor: (Lorg/eclipse/jetty/reactive/client/ContentChunk;)Lorg/springframework/core/io/buffer/DataBuffer;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=3, args_size=2
        start local 0 // org.springframework.http.client.reactive.JettyClientHttpConnector this
        start local 1 // org.eclipse.jetty.reactive.client.ContentChunk chunk
         0: .line 124
            aload 0 /* this */
            getfield org.springframework.http.client.reactive.JettyClientHttpConnector.bufferFactory:Lorg/springframework/core/io/buffer/DataBufferFactory;
            aload 1 /* chunk */
            getfield org.eclipse.jetty.reactive.client.ContentChunk.buffer:Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.capacity:()I
            invokeinterface org.springframework.core.io.buffer.DataBufferFactory.allocateBuffer:(I)Lorg/springframework/core/io/buffer/DataBuffer;
            astore 2 /* buffer */
        start local 2 // org.springframework.core.io.buffer.DataBuffer buffer
         1: .line 125
            aload 2 /* buffer */
            iconst_1
            anewarray java.nio.ByteBuffer
            dup
            iconst_0
            aload 1 /* chunk */
            getfield org.eclipse.jetty.reactive.client.ContentChunk.buffer:Ljava/nio/ByteBuffer;
            aastore
            invokeinterface org.springframework.core.io.buffer.DataBuffer.write:([Ljava/nio/ByteBuffer;)Lorg/springframework/core/io/buffer/DataBuffer;
            pop
         2: .line 126
            aload 1 /* chunk */
            getfield org.eclipse.jetty.reactive.client.ContentChunk.callback:Lorg/eclipse/jetty/util/Callback;
            invokeinterface org.eclipse.jetty.util.Callback.succeeded:()V
         3: .line 127
            aload 2 /* buffer */
            areturn
        end local 2 // org.springframework.core.io.buffer.DataBuffer buffer
        end local 1 // org.eclipse.jetty.reactive.client.ContentChunk chunk
        end local 0 // org.springframework.http.client.reactive.JettyClientHttpConnector this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    4     0    this  Lorg/springframework/http/client/reactive/JettyClientHttpConnector;
            0    4     1   chunk  Lorg/eclipse/jetty/reactive/client/ContentChunk;
            1    4     2  buffer  Lorg/springframework/core/io/buffer/DataBuffer;
    MethodParameters:
       Name  Flags
      chunk  

  private org.reactivestreams.Publisher lambda$0(org.eclipse.jetty.reactive.client.ReactiveResponse, org.reactivestreams.Publisher);
    descriptor: (Lorg/eclipse/jetty/reactive/client/ReactiveResponse;Lorg/reactivestreams/Publisher;)Lorg/reactivestreams/Publisher;
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=4, locals=4, args_size=3
        start local 0 // org.springframework.http.client.reactive.JettyClientHttpConnector this
        start local 1 // org.eclipse.jetty.reactive.client.ReactiveResponse response
        start local 2 // org.reactivestreams.Publisher chunks
         0: .line 110
            aload 2 /* chunks */
            invokestatic reactor.core.publisher.Flux.from:(Lorg/reactivestreams/Publisher;)Lreactor/core/publisher/Flux;
            aload 0 /* this */
            invokedynamic apply(Lorg/springframework/http/client/reactive/JettyClientHttpConnector;)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/JettyClientHttpConnector.toDataBuffer(Lorg/eclipse/jetty/reactive/client/ContentChunk;)Lorg/springframework/core/io/buffer/DataBuffer; (7)
                  (Lorg/eclipse/jetty/reactive/client/ContentChunk;)Lorg/springframework/core/io/buffer/DataBuffer;
            invokevirtual reactor.core.publisher.Flux.map:(Ljava/util/function/Function;)Lreactor/core/publisher/Flux;
            astore 3 /* content */
        start local 3 // reactor.core.publisher.Flux content
         1: .line 111
            new org.springframework.http.client.reactive.JettyClientHttpResponse
            dup
            aload 1 /* response */
            aload 3 /* content */
            invokespecial org.springframework.http.client.reactive.JettyClientHttpResponse.<init>:(Lorg/eclipse/jetty/reactive/client/ReactiveResponse;Lorg/reactivestreams/Publisher;)V
            invokestatic reactor.core.publisher.Mono.just:(Ljava/lang/Object;)Lreactor/core/publisher/Mono;
            areturn
        end local 3 // reactor.core.publisher.Flux content
        end local 2 // org.reactivestreams.Publisher chunks
        end local 1 // org.eclipse.jetty.reactive.client.ReactiveResponse response
        end local 0 // org.springframework.http.client.reactive.JettyClientHttpConnector this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0      this  Lorg/springframework/http/client/reactive/JettyClientHttpConnector;
            0    2     1  response  Lorg/eclipse/jetty/reactive/client/ReactiveResponse;
            0    2     2    chunks  Lorg/reactivestreams/Publisher<Lorg/eclipse/jetty/reactive/client/ContentChunk;>;
            1    2     3   content  Lreactor/core/publisher/Flux<Lorg/springframework/core/io/buffer/DataBuffer;>;
}
SourceFile: "JettyClientHttpConnector.java"
InnerClasses:
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles