class jdk.incubator.http.Stream$PushedStream<U, T> extends jdk.incubator.http.Stream<T>
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: jdk.incubator.http.Stream$PushedStream
  super_class: jdk.incubator.http.Stream
{
  final jdk.incubator.http.PushGroup<U, T> pushGroup;
    descriptor: Ljdk/incubator/http/PushGroup;
    flags: (0x0010) ACC_FINAL
    Signature: Ljdk/incubator/http/PushGroup<TU;TT;>;

  final java.util.concurrent.CompletableFuture<jdk.incubator.http.Response> pushCF;
    descriptor: Ljava/util/concurrent/CompletableFuture;
    flags: (0x0010) ACC_FINAL
    Signature: Ljava/util/concurrent/CompletableFuture<Ljdk/incubator/http/Response;>;

  final java.util.concurrent.CompletableFuture<jdk.incubator.http.HttpResponse<T>> responseCF;
    descriptor: Ljava/util/concurrent/CompletableFuture;
    flags: (0x0010) ACC_FINAL
    Signature: Ljava/util/concurrent/CompletableFuture<Ljdk/incubator/http/HttpResponse<TT;>;>;

  final jdk.incubator.http.HttpRequestImpl pushReq;
    descriptor: Ljdk/incubator/http/HttpRequestImpl;
    flags: (0x0010) ACC_FINAL

  jdk.incubator.http.HttpResponse$BodyHandler<T> pushHandler;
    descriptor: Ljdk/incubator/http/HttpResponse$BodyHandler;
    flags: (0x0000) 
    Signature: Ljdk/incubator/http/HttpResponse$BodyHandler<TT;>;

  void <init>(jdk.incubator.http.PushGroup<U, T>, jdk.incubator.http.Http2Connection, jdk.incubator.http.Exchange<T>);
    descriptor: (Ljdk/incubator/http/PushGroup;Ljdk/incubator/http/Http2Connection;Ljdk/incubator/http/Exchange;)V
    flags: (0x0000) 
    Code:
      stack=4, locals=4, args_size=4
        start local 0 // jdk.incubator.http.Stream$PushedStream this
        start local 1 // jdk.incubator.http.PushGroup pushGroup
        start local 2 // jdk.incubator.http.Http2Connection connection
        start local 3 // jdk.incubator.http.Exchange pushReq
         0: .line 967
            aload 0 /* this */
            aload 2 /* connection */
            aload 3 /* pushReq */
            aconst_null
            invokespecial jdk.incubator.http.Stream.<init>:(Ljdk/incubator/http/Http2Connection;Ljdk/incubator/http/Exchange;Ljdk/incubator/http/WindowController;)V
         1: .line 968
            aload 0 /* this */
            aload 1 /* pushGroup */
            putfield jdk.incubator.http.Stream$PushedStream.pushGroup:Ljdk/incubator/http/PushGroup;
         2: .line 969
            aload 0 /* this */
            aload 3 /* pushReq */
            invokevirtual jdk.incubator.http.Exchange.request:()Ljdk/incubator/http/HttpRequestImpl;
            putfield jdk.incubator.http.Stream$PushedStream.pushReq:Ljdk/incubator/http/HttpRequestImpl;
         3: .line 970
            aload 0 /* this */
            new jdk.incubator.http.internal.common.MinimalFuture
            dup
            invokespecial jdk.incubator.http.internal.common.MinimalFuture.<init>:()V
            putfield jdk.incubator.http.Stream$PushedStream.pushCF:Ljava/util/concurrent/CompletableFuture;
         4: .line 971
            aload 0 /* this */
            new jdk.incubator.http.internal.common.MinimalFuture
            dup
            invokespecial jdk.incubator.http.internal.common.MinimalFuture.<init>:()V
            putfield jdk.incubator.http.Stream$PushedStream.responseCF:Ljava/util/concurrent/CompletableFuture;
         5: .line 972
            return
        end local 3 // jdk.incubator.http.Exchange pushReq
        end local 2 // jdk.incubator.http.Http2Connection connection
        end local 1 // jdk.incubator.http.PushGroup pushGroup
        end local 0 // jdk.incubator.http.Stream$PushedStream this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    6     0        this  Ljdk/incubator/http/Stream$PushedStream<TU;TT;>;
            0    6     1   pushGroup  Ljdk/incubator/http/PushGroup<TU;TT;>;
            0    6     2  connection  Ljdk/incubator/http/Http2Connection;
            0    6     3     pushReq  Ljdk/incubator/http/Exchange<TT;>;
    Signature: (Ljdk/incubator/http/PushGroup<TU;TT;>;Ljdk/incubator/http/Http2Connection;Ljdk/incubator/http/Exchange<TT;>;)V
    MethodParameters:
            Name  Flags
      pushGroup   
      connection  
      pushReq     

  java.util.concurrent.CompletableFuture<jdk.incubator.http.HttpResponse<T>> responseCF();
    descriptor: ()Ljava/util/concurrent/CompletableFuture;
    flags: (0x0000) 
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // jdk.incubator.http.Stream$PushedStream this
         0: .line 975
            aload 0 /* this */
            getfield jdk.incubator.http.Stream$PushedStream.responseCF:Ljava/util/concurrent/CompletableFuture;
            areturn
        end local 0 // jdk.incubator.http.Stream$PushedStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Ljdk/incubator/http/Stream$PushedStream<TU;TT;>;
    Signature: ()Ljava/util/concurrent/CompletableFuture<Ljdk/incubator/http/HttpResponse<TT;>;>;

  synchronized void setPushHandler(jdk.incubator.http.HttpResponse$BodyHandler<T>);
    descriptor: (Ljdk/incubator/http/HttpResponse$BodyHandler;)V
    flags: (0x0020) ACC_SYNCHRONIZED
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // jdk.incubator.http.Stream$PushedStream this
        start local 1 // jdk.incubator.http.HttpResponse$BodyHandler pushHandler
         0: .line 979
            aload 0 /* this */
            aload 1 /* pushHandler */
            putfield jdk.incubator.http.Stream$PushedStream.pushHandler:Ljdk/incubator/http/HttpResponse$BodyHandler;
         1: .line 980
            return
        end local 1 // jdk.incubator.http.HttpResponse$BodyHandler pushHandler
        end local 0 // jdk.incubator.http.Stream$PushedStream this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    2     0         this  Ljdk/incubator/http/Stream$PushedStream<TU;TT;>;
            0    2     1  pushHandler  Ljdk/incubator/http/HttpResponse$BodyHandler<TT;>;
    Signature: (Ljdk/incubator/http/HttpResponse$BodyHandler<TT;>;)V
    MethodParameters:
             Name  Flags
      pushHandler  

  synchronized jdk.incubator.http.HttpResponse$BodyHandler<T> getPushHandler();
    descriptor: ()Ljdk/incubator/http/HttpResponse$BodyHandler;
    flags: (0x0020) ACC_SYNCHRONIZED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // jdk.incubator.http.Stream$PushedStream this
         0: .line 984
            aload 0 /* this */
            getfield jdk.incubator.http.Stream$PushedStream.pushHandler:Ljdk/incubator/http/HttpResponse$BodyHandler;
            areturn
        end local 0 // jdk.incubator.http.Stream$PushedStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Ljdk/incubator/http/Stream$PushedStream<TU;TT;>;
    Signature: ()Ljdk/incubator/http/HttpResponse$BodyHandler<TT;>;

  java.util.concurrent.CompletableFuture<jdk.incubator.http.ExchangeImpl<T>> sendBodyAsync();
    descriptor: ()Ljava/util/concurrent/CompletableFuture;
    flags: (0x0000) 
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // jdk.incubator.http.Stream$PushedStream this
         0: .line 992
            aload 0 /* this */
            invokespecial jdk.incubator.http.Stream.sendBodyAsync:()Ljava/util/concurrent/CompletableFuture;
         1: .line 993
            aload 0 /* this */
            invokedynamic accept(Ljdk/incubator/http/Stream$PushedStream;)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
                  jdk/incubator/http/Stream$PushedStream.lambda$0(Ljdk/incubator/http/ExchangeImpl;Ljava/lang/Throwable;)V (7)
                  (Ljdk/incubator/http/ExchangeImpl;Ljava/lang/Throwable;)V
            invokevirtual java.util.concurrent.CompletableFuture.whenComplete:(Ljava/util/function/BiConsumer;)Ljava/util/concurrent/CompletableFuture;
         2: .line 992
            areturn
        end local 0 // jdk.incubator.http.Stream$PushedStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Ljdk/incubator/http/Stream$PushedStream<TU;TT;>;
    Signature: ()Ljava/util/concurrent/CompletableFuture<Ljdk/incubator/http/ExchangeImpl<TT;>;>;

  java.util.concurrent.CompletableFuture<jdk.incubator.http.ExchangeImpl<T>> sendHeadersAsync();
    descriptor: ()Ljava/util/concurrent/CompletableFuture;
    flags: (0x0000) 
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // jdk.incubator.http.Stream$PushedStream this
         0: .line 999
            aload 0 /* this */
            invokespecial jdk.incubator.http.Stream.sendHeadersAsync:()Ljava/util/concurrent/CompletableFuture;
         1: .line 1000
            aload 0 /* this */
            invokedynamic accept(Ljdk/incubator/http/Stream$PushedStream;)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
                  jdk/incubator/http/Stream$PushedStream.lambda$1(Ljdk/incubator/http/ExchangeImpl;Ljava/lang/Throwable;)V (7)
                  (Ljdk/incubator/http/ExchangeImpl;Ljava/lang/Throwable;)V
            invokevirtual java.util.concurrent.CompletableFuture.whenComplete:(Ljava/util/function/BiConsumer;)Ljava/util/concurrent/CompletableFuture;
         2: .line 999
            areturn
        end local 0 // jdk.incubator.http.Stream$PushedStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Ljdk/incubator/http/Stream$PushedStream<TU;TT;>;
    Signature: ()Ljava/util/concurrent/CompletableFuture<Ljdk/incubator/http/ExchangeImpl<TT;>;>;

  java.util.concurrent.CompletableFuture<jdk.incubator.http.Response> getResponseAsync(java.util.concurrent.Executor);
    descriptor: (Ljava/util/concurrent/Executor;)Ljava/util/concurrent/CompletableFuture;
    flags: (0x0000) 
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // jdk.incubator.http.Stream$PushedStream this
        start local 1 // java.util.concurrent.Executor executor
         0: .line 1006
            aload 0 /* this */
            getfield jdk.incubator.http.Stream$PushedStream.pushCF:Ljava/util/concurrent/CompletableFuture;
         1: .line 1007
            aload 0 /* this */
            invokedynamic accept(Ljdk/incubator/http/Stream$PushedStream;)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
                  jdk/incubator/http/Stream$PushedStream.lambda$2(Ljdk/incubator/http/Response;Ljava/lang/Throwable;)V (7)
                  (Ljdk/incubator/http/Response;Ljava/lang/Throwable;)V
         2: .line 1006
            invokevirtual java.util.concurrent.CompletableFuture.whenComplete:(Ljava/util/function/BiConsumer;)Ljava/util/concurrent/CompletableFuture;
            astore 2 /* cf */
        start local 2 // java.util.concurrent.CompletableFuture cf
         3: .line 1008
            aload 1 /* executor */
            ifnull 5
            aload 2 /* cf */
            invokevirtual java.util.concurrent.CompletableFuture.isDone:()Z
            ifne 5
         4: .line 1009
            aload 2 /* cf */
            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;
                  jdk/incubator/http/Stream$PushedStream.lambda$3(Ljdk/incubator/http/Response;)Ljdk/incubator/http/Response; (6)
                  (Ljdk/incubator/http/Response;)Ljdk/incubator/http/Response;
            aload 1 /* executor */
            invokevirtual java.util.concurrent.CompletableFuture.thenApplyAsync:(Ljava/util/function/Function;Ljava/util/concurrent/Executor;)Ljava/util/concurrent/CompletableFuture;
            astore 2 /* cf */
         5: .line 1011
      StackMap locals: java.util.concurrent.CompletableFuture
      StackMap stack:
            aload 2 /* cf */
            areturn
        end local 2 // java.util.concurrent.CompletableFuture cf
        end local 1 // java.util.concurrent.Executor executor
        end local 0 // jdk.incubator.http.Stream$PushedStream this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    6     0      this  Ljdk/incubator/http/Stream$PushedStream<TU;TT;>;
            0    6     1  executor  Ljava/util/concurrent/Executor;
            3    6     2        cf  Ljava/util/concurrent/CompletableFuture<Ljdk/incubator/http/Response;>;
    Signature: (Ljava/util/concurrent/Executor;)Ljava/util/concurrent/CompletableFuture<Ljdk/incubator/http/Response;>;
    MethodParameters:
          Name  Flags
      executor  

  java.util.concurrent.CompletableFuture<T> readBodyAsync(jdk.incubator.http.HttpResponse$BodyHandler<T>, boolean, java.util.concurrent.Executor);
    descriptor: (Ljdk/incubator/http/HttpResponse$BodyHandler;ZLjava/util/concurrent/Executor;)Ljava/util/concurrent/CompletableFuture;
    flags: (0x0000) 
    Code:
      stack=4, locals=4, args_size=4
        start local 0 // jdk.incubator.http.Stream$PushedStream this
        start local 1 // jdk.incubator.http.HttpResponse$BodyHandler handler
        start local 2 // boolean returnConnectionToPool
        start local 3 // java.util.concurrent.Executor executor
         0: .line 1020
            aload 0 /* this */
            aload 1 /* handler */
            iload 2 /* returnConnectionToPool */
            aload 3 /* executor */
            invokespecial jdk.incubator.http.Stream.readBodyAsync:(Ljdk/incubator/http/HttpResponse$BodyHandler;ZLjava/util/concurrent/Executor;)Ljava/util/concurrent/CompletableFuture;
         1: .line 1021
            aload 0 /* this */
            invokedynamic accept(Ljdk/incubator/http/Stream$PushedStream;)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
                  jdk/incubator/http/Stream$PushedStream.lambda$4(Ljava/lang/Object;Ljava/lang/Throwable;)V (7)
                  (Ljava/lang/Object;Ljava/lang/Throwable;)V
            invokevirtual java.util.concurrent.CompletableFuture.whenComplete:(Ljava/util/function/BiConsumer;)Ljava/util/concurrent/CompletableFuture;
         2: .line 1020
            areturn
        end local 3 // java.util.concurrent.Executor executor
        end local 2 // boolean returnConnectionToPool
        end local 1 // jdk.incubator.http.HttpResponse$BodyHandler handler
        end local 0 // jdk.incubator.http.Stream$PushedStream this
      LocalVariableTable:
        Start  End  Slot                    Name  Signature
            0    3     0                    this  Ljdk/incubator/http/Stream$PushedStream<TU;TT;>;
            0    3     1                 handler  Ljdk/incubator/http/HttpResponse$BodyHandler<TT;>;
            0    3     2  returnConnectionToPool  Z
            0    3     3                executor  Ljava/util/concurrent/Executor;
    Signature: (Ljdk/incubator/http/HttpResponse$BodyHandler<TT;>;ZLjava/util/concurrent/Executor;)Ljava/util/concurrent/CompletableFuture<TT;>;
    MethodParameters:
                        Name  Flags
      handler                 
      returnConnectionToPool  
      executor                

  void completeResponse(jdk.incubator.http.Response);
    descriptor: (Ljdk/incubator/http/Response;)V
    flags: (0x0000) 
    Code:
      stack=3, locals=4, args_size=2
        start local 0 // jdk.incubator.http.Stream$PushedStream this
        start local 1 // jdk.incubator.http.Response r
         0: .line 1026
            aload 1 /* r */
            dup
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            pop
            invokedynamic get(Ljdk/incubator/http/Response;)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;
                  jdk/incubator/http/Response.toString()Ljava/lang/String; (5)
                  ()Ljava/lang/String;
            invokestatic jdk.incubator.http.internal.common.Log.logResponse:(Ljava/util/function/Supplier;)V
         1: .line 1027
            aload 0 /* this */
            getfield jdk.incubator.http.Stream$PushedStream.pushCF:Ljava/util/concurrent/CompletableFuture;
            aload 1 /* r */
            invokevirtual java.util.concurrent.CompletableFuture.complete:(Ljava/lang/Object;)Z
            pop
         2: .line 1029
            new jdk.incubator.http.internal.common.MinimalFuture
            dup
            invokespecial jdk.incubator.http.internal.common.MinimalFuture.<init>:()V
            astore 3 /* start */
        start local 3 // java.util.concurrent.CompletableFuture start
         3: .line 1030
            aload 3 /* start */
            aload 0 /* this */
            invokedynamic apply(Ljdk/incubator/http/Stream$PushedStream;)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;
                  jdk/incubator/http/Stream$PushedStream.lambda$6(Ljava/lang/Void;)Ljava/util/concurrent/CompletionStage; (7)
                  (Ljava/lang/Void;)Ljava/util/concurrent/CompletionStage;
            invokevirtual java.util.concurrent.CompletableFuture.thenCompose:(Ljava/util/function/Function;)Ljava/util/concurrent/CompletableFuture;
         4: .line 1031
            aload 0 /* this */
            aload 1 /* r */
            invokedynamic accept(Ljdk/incubator/http/Stream$PushedStream;Ljdk/incubator/http/Response;)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
                  jdk/incubator/http/Stream$PushedStream.lambda$7(Ljdk/incubator/http/Response;Ljava/lang/Object;Ljava/lang/Throwable;)V (7)
                  (Ljava/lang/Object;Ljava/lang/Throwable;)V
            invokevirtual java.util.concurrent.CompletableFuture.whenComplete:(Ljava/util/function/BiConsumer;)Ljava/util/concurrent/CompletableFuture;
            pop
         5: .line 1040
            aload 3 /* start */
            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;
                  jdk/incubator/http/Stream$PushedStream.lambda$8()Ljava/lang/Void; (6)
                  ()Ljava/lang/Void;
            aload 0 /* this */
            invokevirtual jdk.incubator.http.Stream$PushedStream.getExchange:()Ljdk/incubator/http/Exchange;
            invokevirtual jdk.incubator.http.Exchange.executor:()Ljava/util/concurrent/Executor;
            invokevirtual java.util.concurrent.CompletableFuture.completeAsync:(Ljava/util/function/Supplier;Ljava/util/concurrent/Executor;)Ljava/util/concurrent/CompletableFuture;
            pop
         6: .line 1041
            return
        end local 3 // java.util.concurrent.CompletableFuture start
        end local 1 // jdk.incubator.http.Response r
        end local 0 // jdk.incubator.http.Stream$PushedStream this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    7     0   this  Ljdk/incubator/http/Stream$PushedStream<TU;TT;>;
            0    7     1      r  Ljdk/incubator/http/Response;
            3    7     3  start  Ljava/util/concurrent/CompletableFuture<Ljava/lang/Void;>;
    MethodParameters:
      Name  Flags
      r     

  void completeResponseExceptionally(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x0000) 
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // jdk.incubator.http.Stream$PushedStream this
        start local 1 // java.lang.Throwable t
         0: .line 1045
            aload 0 /* this */
            getfield jdk.incubator.http.Stream$PushedStream.pushCF:Ljava/util/concurrent/CompletableFuture;
            aload 1 /* t */
            invokevirtual java.util.concurrent.CompletableFuture.completeExceptionally:(Ljava/lang/Throwable;)Z
            pop
         1: .line 1046
            return
        end local 1 // java.lang.Throwable t
        end local 0 // jdk.incubator.http.Stream$PushedStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Ljdk/incubator/http/Stream$PushedStream<TU;TT;>;
            0    2     1     t  Ljava/lang/Throwable;
    MethodParameters:
      Name  Flags
      t     

  protected void handleResponse();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=8, locals=2, args_size=1
        start local 0 // jdk.incubator.http.Stream$PushedStream this
         0: .line 1056
            aload 0 /* this */
            aload 0 /* this */
            getfield jdk.incubator.http.Stream$PushedStream.responseHeaders:Ljdk/incubator/http/internal/common/HttpHeadersImpl;
         1: .line 1057
            ldc ":status"
            invokevirtual jdk.incubator.http.internal.common.HttpHeadersImpl.firstValueAsLong:(Ljava/lang/String;)Ljava/util/OptionalLong;
         2: .line 1058
            ldc -1
            invokevirtual java.util.OptionalLong.orElse:(J)J
            l2i
         3: .line 1056
            putfield jdk.incubator.http.Stream$PushedStream.responseCode:I
         4: .line 1060
            aload 0 /* this */
            getfield jdk.incubator.http.Stream$PushedStream.responseCode:I
            iconst_m1
            if_icmpne 6
         5: .line 1061
            aload 0 /* this */
            new java.io.IOException
            dup
            ldc "No status code"
            invokespecial java.io.IOException.<init>:(Ljava/lang/String;)V
            invokevirtual jdk.incubator.http.Stream$PushedStream.completeResponseExceptionally:(Ljava/lang/Throwable;)V
         6: .line 1064
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            new jdk.incubator.http.Response
            dup
         7: .line 1065
            aload 0 /* this */
            getfield jdk.incubator.http.Stream$PushedStream.pushReq:Ljdk/incubator/http/HttpRequestImpl;
            aload 0 /* this */
            getfield jdk.incubator.http.Stream$PushedStream.exchange:Ljdk/incubator/http/Exchange;
            aload 0 /* this */
            getfield jdk.incubator.http.Stream$PushedStream.responseHeaders:Ljdk/incubator/http/internal/common/HttpHeadersImpl;
         8: .line 1066
            aload 0 /* this */
            getfield jdk.incubator.http.Stream$PushedStream.responseCode:I
            getstatic jdk.incubator.http.HttpClient$Version.HTTP_2:Ljdk/incubator/http/HttpClient$Version;
            invokespecial jdk.incubator.http.Response.<init>:(Ljdk/incubator/http/HttpRequestImpl;Ljdk/incubator/http/Exchange;Ljdk/incubator/http/HttpHeaders;ILjdk/incubator/http/HttpClient$Version;)V
         9: .line 1064
            putfield jdk.incubator.http.Stream$PushedStream.response:Ljdk/incubator/http/Response;
        10: .line 1072
            aload 0 /* this */
            getfield jdk.incubator.http.Stream$PushedStream.responseHeaders:Ljdk/incubator/http/internal/common/HttpHeadersImpl;
            ldc "content-length"
            invokevirtual jdk.incubator.http.internal.common.HttpHeadersImpl.firstValueAsLong:(Ljava/lang/String;)Ljava/util/OptionalLong;
            pop
        11: .line 1074
            invokestatic jdk.incubator.http.internal.common.Log.headers:()Z
            ifeq 16
        12: .line 1075
            new java.lang.StringBuilder
            dup
            ldc "RESPONSE HEADERS"
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            astore 1 /* sb */
        start local 1 // java.lang.StringBuilder sb
        13: .line 1076
            aload 1 /* sb */
            ldc " (streamid="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 0 /* this */
            getfield jdk.incubator.http.Stream$PushedStream.streamid:I
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            ldc "): "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            pop
        14: .line 1077
            aload 1 /* sb */
            ldc "    "
            aload 0 /* this */
            getfield jdk.incubator.http.Stream$PushedStream.responseHeaders:Ljdk/incubator/http/internal/common/HttpHeadersImpl;
            invokestatic jdk.incubator.http.internal.common.Log.dumpHeaders:(Ljava/lang/StringBuilder;Ljava/lang/String;Ljdk/incubator/http/HttpHeaders;)V
        15: .line 1078
            aload 1 /* sb */
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            iconst_0
            anewarray java.lang.Object
            invokestatic jdk.incubator.http.internal.common.Log.logHeaders:(Ljava/lang/String;[Ljava/lang/Object;)V
        end local 1 // java.lang.StringBuilder sb
        16: .line 1082
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 0 /* this */
            getfield jdk.incubator.http.Stream$PushedStream.response:Ljdk/incubator/http/Response;
            invokevirtual jdk.incubator.http.Stream$PushedStream.completeResponse:(Ljdk/incubator/http/Response;)V
        17: .line 1083
            return
        end local 0 // jdk.incubator.http.Stream$PushedStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   18     0  this  Ljdk/incubator/http/Stream$PushedStream<TU;TT;>;
           13   16     1    sb  Ljava/lang/StringBuilder;

  private void lambda$0(jdk.incubator.http.ExchangeImpl, java.lang.Throwable);
    descriptor: (Ljdk/incubator/http/ExchangeImpl;Ljava/lang/Throwable;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=3
        start local 0 // jdk.incubator.http.Stream$PushedStream this
        start local 1 // jdk.incubator.http.ExchangeImpl v
        start local 2 // java.lang.Throwable t
         0: .line 994
            aload 0 /* this */
            getfield jdk.incubator.http.Stream$PushedStream.pushGroup:Ljdk/incubator/http/PushGroup;
            aload 2 /* t */
            invokestatic jdk.incubator.http.internal.common.Utils.getCompletionCause:(Ljava/lang/Throwable;)Ljava/lang/Throwable;
            invokevirtual jdk.incubator.http.PushGroup.pushError:(Ljava/lang/Throwable;)V
            return
        end local 2 // java.lang.Throwable t
        end local 1 // jdk.incubator.http.ExchangeImpl v
        end local 0 // jdk.incubator.http.Stream$PushedStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Ljdk/incubator/http/Stream$PushedStream<TU;TT;>;
            0    1     1     v  Ljdk/incubator/http/ExchangeImpl<TT;>;
            0    1     2     t  Ljava/lang/Throwable;

  private void lambda$1(jdk.incubator.http.ExchangeImpl, java.lang.Throwable);
    descriptor: (Ljdk/incubator/http/ExchangeImpl;Ljava/lang/Throwable;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=3
        start local 0 // jdk.incubator.http.Stream$PushedStream this
        start local 1 // jdk.incubator.http.ExchangeImpl ex
        start local 2 // java.lang.Throwable t
         0: .line 1001
            aload 0 /* this */
            getfield jdk.incubator.http.Stream$PushedStream.pushGroup:Ljdk/incubator/http/PushGroup;
            aload 2 /* t */
            invokestatic jdk.incubator.http.internal.common.Utils.getCompletionCause:(Ljava/lang/Throwable;)Ljava/lang/Throwable;
            invokevirtual jdk.incubator.http.PushGroup.pushError:(Ljava/lang/Throwable;)V
            return
        end local 2 // java.lang.Throwable t
        end local 1 // jdk.incubator.http.ExchangeImpl ex
        end local 0 // jdk.incubator.http.Stream$PushedStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Ljdk/incubator/http/Stream$PushedStream<TU;TT;>;
            0    1     1    ex  Ljdk/incubator/http/ExchangeImpl<TT;>;
            0    1     2     t  Ljava/lang/Throwable;

  private void lambda$2(jdk.incubator.http.Response, java.lang.Throwable);
    descriptor: (Ljdk/incubator/http/Response;Ljava/lang/Throwable;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=3
        start local 0 // jdk.incubator.http.Stream$PushedStream this
        start local 1 // jdk.incubator.http.Response v
        start local 2 // java.lang.Throwable t
         0: .line 1007
            aload 0 /* this */
            getfield jdk.incubator.http.Stream$PushedStream.pushGroup:Ljdk/incubator/http/PushGroup;
            aload 2 /* t */
            invokestatic jdk.incubator.http.internal.common.Utils.getCompletionCause:(Ljava/lang/Throwable;)Ljava/lang/Throwable;
            invokevirtual jdk.incubator.http.PushGroup.pushError:(Ljava/lang/Throwable;)V
            return
        end local 2 // java.lang.Throwable t
        end local 1 // jdk.incubator.http.Response v
        end local 0 // jdk.incubator.http.Stream$PushedStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Ljdk/incubator/http/Stream$PushedStream<TU;TT;>;
            0    1     1     v  Ljdk/incubator/http/Response;
            0    1     2     t  Ljava/lang/Throwable;

  private static jdk.incubator.http.Response lambda$3(jdk.incubator.http.Response);
    descriptor: (Ljdk/incubator/http/Response;)Ljdk/incubator/http/Response;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // jdk.incubator.http.Response r
         0: .line 1009
            aload 0 /* r */
            areturn
        end local 0 // jdk.incubator.http.Response r
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0     r  Ljdk/incubator/http/Response;

  private void lambda$4(java.lang.Object, java.lang.Throwable);
    descriptor: (Ljava/lang/Object;Ljava/lang/Throwable;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=3
        start local 0 // jdk.incubator.http.Stream$PushedStream this
        start local 1 // java.lang.Object v
        start local 2 // java.lang.Throwable t
         0: .line 1021
            aload 0 /* this */
            getfield jdk.incubator.http.Stream$PushedStream.pushGroup:Ljdk/incubator/http/PushGroup;
            aload 2 /* t */
            invokevirtual jdk.incubator.http.PushGroup.pushError:(Ljava/lang/Throwable;)V
            return
        end local 2 // java.lang.Throwable t
        end local 1 // java.lang.Object v
        end local 0 // jdk.incubator.http.Stream$PushedStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Ljdk/incubator/http/Stream$PushedStream<TU;TT;>;
            0    1     1     v  TT;
            0    1     2     t  Ljava/lang/Throwable;

  private java.util.concurrent.CompletionStage lambda$6(java.lang.Void);
    descriptor: (Ljava/lang/Void;)Ljava/util/concurrent/CompletionStage;
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // jdk.incubator.http.Stream$PushedStream this
        start local 1 // java.lang.Void v
         0: .line 1030
            aload 0 /* this */
            aload 0 /* this */
            invokevirtual jdk.incubator.http.Stream$PushedStream.getPushHandler:()Ljdk/incubator/http/HttpResponse$BodyHandler;
            iconst_0
            aload 0 /* this */
            invokevirtual jdk.incubator.http.Stream$PushedStream.getExchange:()Ljdk/incubator/http/Exchange;
            invokevirtual jdk.incubator.http.Exchange.executor:()Ljava/util/concurrent/Executor;
            invokevirtual jdk.incubator.http.Stream$PushedStream.readBodyAsync:(Ljdk/incubator/http/HttpResponse$BodyHandler;ZLjava/util/concurrent/Executor;)Ljava/util/concurrent/CompletableFuture;
            areturn
        end local 1 // java.lang.Void v
        end local 0 // jdk.incubator.http.Stream$PushedStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Ljdk/incubator/http/Stream$PushedStream<TU;TT;>;
            0    1     1     v  Ljava/lang/Void;

  private void lambda$7(jdk.incubator.http.Response, java.lang.Object, java.lang.Throwable);
    descriptor: (Ljdk/incubator/http/Response;Ljava/lang/Object;Ljava/lang/Throwable;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=7, locals=5, args_size=4
        start local 0 // jdk.incubator.http.Stream$PushedStream this
        start local 2 // java.lang.Object body
        start local 3 // java.lang.Throwable t
         0: .line 1032
            aload 3 /* t */
            ifnull 3
         1: .line 1033
            aload 0 /* this */
            getfield jdk.incubator.http.Stream$PushedStream.responseCF:Ljava/util/concurrent/CompletableFuture;
            aload 3 /* t */
            invokevirtual java.util.concurrent.CompletableFuture.completeExceptionally:(Ljava/lang/Throwable;)Z
            pop
         2: .line 1034
            goto 6
         3: .line 1036
      StackMap locals:
      StackMap stack:
            new jdk.incubator.http.HttpResponseImpl
            dup
            aload 1
            getfield jdk.incubator.http.Response.request:Ljdk/incubator/http/HttpRequestImpl;
            aload 1
            aconst_null
            aload 2 /* body */
            aload 0 /* this */
            invokevirtual jdk.incubator.http.Stream$PushedStream.getExchange:()Ljdk/incubator/http/Exchange;
            invokespecial jdk.incubator.http.HttpResponseImpl.<init>:(Ljdk/incubator/http/HttpRequest;Ljdk/incubator/http/Response;Ljdk/incubator/http/HttpResponse;Ljava/lang/Object;Ljdk/incubator/http/Exchange;)V
         4: .line 1035
            astore 4 /* resp */
        start local 4 // jdk.incubator.http.HttpResponseImpl resp
         5: .line 1037
            aload 0 /* this */
            getfield jdk.incubator.http.Stream$PushedStream.responseCF:Ljava/util/concurrent/CompletableFuture;
            aload 4 /* resp */
            invokevirtual java.util.concurrent.CompletableFuture.complete:(Ljava/lang/Object;)Z
            pop
        end local 4 // jdk.incubator.http.HttpResponseImpl resp
         6: .line 1039
      StackMap locals:
      StackMap stack:
            return
        end local 3 // java.lang.Throwable t
        end local 2 // java.lang.Object body
        end local 0 // jdk.incubator.http.Stream$PushedStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    7     0  this  Ljdk/incubator/http/Stream$PushedStream<TU;TT;>;
            0    7     2  body  TT;
            0    7     3     t  Ljava/lang/Throwable;
            5    6     4  resp  Ljdk/incubator/http/HttpResponseImpl<TT;>;

  private static java.lang.Void lambda$8();
    descriptor: ()Ljava/lang/Void;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 1040
            aconst_null
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
}
Signature: <U:Ljava/lang/Object;T:Ljava/lang/Object;>Ljdk/incubator/http/Stream<TT;>;
SourceFile: "Stream.java"
NestHost: jdk.incubator.http.Stream
InnerClasses:
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
  public final Version = jdk.incubator.http.HttpClient$Version of jdk.incubator.http.HttpClient
  public abstract BodyHandler = jdk.incubator.http.HttpResponse$BodyHandler of jdk.incubator.http.HttpResponse
  PushedStream = jdk.incubator.http.Stream$PushedStream of jdk.incubator.http.Stream