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

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

  java.util.concurrent.CompletableFuture<java.net.http.HttpResponse<T>> responseCF;
    descriptor: Ljava/util/concurrent/CompletableFuture;
    flags: (0x0000) 
    Signature: Ljava/util/concurrent/CompletableFuture<Ljava/net/http/HttpResponse<TT;>;>;

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

  java.net.http.HttpResponse$BodyHandler<T> pushHandler;
    descriptor: Ljava/net/http/HttpResponse$BodyHandler;
    flags: (0x0000) 
    Signature: Ljava/net/http/HttpResponse$BodyHandler<TT;>;

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

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

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

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

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

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

  java.util.concurrent.CompletableFuture<jdk.internal.net.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.internal.net.http.Stream$PushedStream this
        start local 1 // java.util.concurrent.Executor executor
         0: .line 1234
            aload 0 /* this */
            getfield jdk.internal.net.http.Stream$PushedStream.pushCF:Ljava/util/concurrent/CompletableFuture;
         1: .line 1235
            aload 0 /* this */
            invokedynamic accept(Ljdk/internal/net/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/internal/net/http/Stream$PushedStream.lambda$2(Ljdk/internal/net/http/Response;Ljava/lang/Throwable;)V (7)
                  (Ljdk/internal/net/http/Response;Ljava/lang/Throwable;)V
         2: .line 1234
            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 1236
            aload 1 /* executor */
            ifnull 5
            aload 2 /* cf */
            invokevirtual java.util.concurrent.CompletableFuture.isDone:()Z
            ifne 5
         4: .line 1237
            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/internal/net/http/Stream$PushedStream.lambda$3(Ljdk/internal/net/http/Response;)Ljdk/internal/net/http/Response; (6)
                  (Ljdk/internal/net/http/Response;)Ljdk/internal/net/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 1239
      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.internal.net.http.Stream$PushedStream this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    6     0      this  Ljdk/internal/net/http/Stream$PushedStream<TT;>;
            0    6     1  executor  Ljava/util/concurrent/Executor;
            3    6     2        cf  Ljava/util/concurrent/CompletableFuture<Ljdk/internal/net/http/Response;>;
    Signature: (Ljava/util/concurrent/Executor;)Ljava/util/concurrent/CompletableFuture<Ljdk/internal/net/http/Response;>;
    MethodParameters:
          Name  Flags
      executor  

  java.util.concurrent.CompletableFuture<T> readBodyAsync(java.net.http.HttpResponse$BodyHandler<T>, boolean, java.util.concurrent.Executor);
    descriptor: (Ljava/net/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.internal.net.http.Stream$PushedStream this
        start local 1 // java.net.http.HttpResponse$BodyHandler handler
        start local 2 // boolean returnConnectionToPool
        start local 3 // java.util.concurrent.Executor executor
         0: .line 1248
            aload 0 /* this */
            aload 1 /* handler */
            iload 2 /* returnConnectionToPool */
            aload 3 /* executor */
            invokespecial jdk.internal.net.http.Stream.readBodyAsync:(Ljava/net/http/HttpResponse$BodyHandler;ZLjava/util/concurrent/Executor;)Ljava/util/concurrent/CompletableFuture;
         1: .line 1249
            aload 0 /* this */
            invokedynamic accept(Ljdk/internal/net/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/internal/net/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 1248
            areturn
        end local 3 // java.util.concurrent.Executor executor
        end local 2 // boolean returnConnectionToPool
        end local 1 // java.net.http.HttpResponse$BodyHandler handler
        end local 0 // jdk.internal.net.http.Stream$PushedStream this
      LocalVariableTable:
        Start  End  Slot                    Name  Signature
            0    3     0                    this  Ljdk/internal/net/http/Stream$PushedStream<TT;>;
            0    3     1                 handler  Ljava/net/http/HttpResponse$BodyHandler<TT;>;
            0    3     2  returnConnectionToPool  Z
            0    3     3                executor  Ljava/util/concurrent/Executor;
    Signature: (Ljava/net/http/HttpResponse$BodyHandler<TT;>;ZLjava/util/concurrent/Executor;)Ljava/util/concurrent/CompletableFuture<TT;>;
    MethodParameters:
                        Name  Flags
      handler                 
      returnConnectionToPool  
      executor                

  void completeResponse(jdk.internal.net.http.Response);
    descriptor: (Ljdk/internal/net/http/Response;)V
    flags: (0x0000) 
    Code:
      stack=3, locals=4, args_size=2
        start local 0 // jdk.internal.net.http.Stream$PushedStream this
        start local 1 // jdk.internal.net.http.Response r
         0: .line 1254
            aload 1 /* r */
            dup
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            pop
            invokedynamic get(Ljdk/internal/net/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/internal/net/http/Response.toString()Ljava/lang/String; (5)
                  ()Ljava/lang/String;
            invokestatic jdk.internal.net.http.common.Log.logResponse:(Ljava/util/function/Supplier;)V
         1: .line 1255
            aload 0 /* this */
            getfield jdk.internal.net.http.Stream$PushedStream.pushCF:Ljava/util/concurrent/CompletableFuture;
            aload 1 /* r */
            invokevirtual java.util.concurrent.CompletableFuture.complete:(Ljava/lang/Object;)Z
            pop
         2: .line 1257
            new jdk.internal.net.http.common.MinimalFuture
            dup
            invokespecial jdk.internal.net.http.common.MinimalFuture.<init>:()V
            astore 3 /* start */
        start local 3 // java.util.concurrent.CompletableFuture start
         3: .line 1258
            aload 3 /* start */
            aload 0 /* this */
            invokedynamic apply(Ljdk/internal/net/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/internal/net/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 1259
            aload 0 /* this */
            aload 1 /* r */
            invokedynamic accept(Ljdk/internal/net/http/Stream$PushedStream;Ljdk/internal/net/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/internal/net/http/Stream$PushedStream.lambda$7(Ljdk/internal/net/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 1268
            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/internal/net/http/Stream$PushedStream.lambda$8()Ljava/lang/Void; (6)
                  ()Ljava/lang/Void;
            aload 0 /* this */
            invokevirtual jdk.internal.net.http.Stream$PushedStream.getExchange:()Ljdk/internal/net/http/Exchange;
            invokevirtual jdk.internal.net.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 1269
            return
        end local 3 // java.util.concurrent.CompletableFuture start
        end local 1 // jdk.internal.net.http.Response r
        end local 0 // jdk.internal.net.http.Stream$PushedStream this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    7     0   this  Ljdk/internal/net/http/Stream$PushedStream<TT;>;
            0    7     1      r  Ljdk/internal/net/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.internal.net.http.Stream$PushedStream this
        start local 1 // java.lang.Throwable t
         0: .line 1273
            aload 0 /* this */
            getfield jdk.internal.net.http.Stream$PushedStream.pushCF:Ljava/util/concurrent/CompletableFuture;
            aload 1 /* t */
            invokevirtual java.util.concurrent.CompletableFuture.completeExceptionally:(Ljava/lang/Throwable;)Z
            pop
         1: .line 1274
            return
        end local 1 // java.lang.Throwable t
        end local 0 // jdk.internal.net.http.Stream$PushedStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Ljdk/internal/net/http/Stream$PushedStream<TT;>;
            0    2     1     t  Ljava/lang/Throwable;
    MethodParameters:
      Name  Flags
      t     

  protected void handleResponse();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=9, locals=3, args_size=1
        start local 0 // jdk.internal.net.http.Stream$PushedStream this
         0: .line 1284
            aload 0 /* this */
            getfield jdk.internal.net.http.Stream$PushedStream.responseHeadersBuilder:Ljdk/internal/net/http/common/HttpHeadersBuilder;
            invokevirtual jdk.internal.net.http.common.HttpHeadersBuilder.build:()Ljava/net/http/HttpHeaders;
            astore 1 /* responseHeaders */
        start local 1 // java.net.http.HttpHeaders responseHeaders
         1: .line 1285
            aload 0 /* this */
            aload 1 /* responseHeaders */
         2: .line 1286
            ldc ":status"
            invokevirtual java.net.http.HttpHeaders.firstValueAsLong:(Ljava/lang/String;)Ljava/util/OptionalLong;
         3: .line 1287
            ldc -1
            invokevirtual java.util.OptionalLong.orElse:(J)J
            l2i
         4: .line 1285
            putfield jdk.internal.net.http.Stream$PushedStream.responseCode:I
         5: .line 1289
            aload 0 /* this */
            getfield jdk.internal.net.http.Stream$PushedStream.responseCode:I
            iconst_m1
            if_icmpne 7
         6: .line 1290
            aload 0 /* this */
            new java.io.IOException
            dup
            ldc "No status code"
            invokespecial java.io.IOException.<init>:(Ljava/lang/String;)V
            invokevirtual jdk.internal.net.http.Stream$PushedStream.completeResponseExceptionally:(Ljava/lang/Throwable;)V
         7: .line 1293
      StackMap locals: java.net.http.HttpHeaders
      StackMap stack:
            aload 0 /* this */
            new jdk.internal.net.http.Response
            dup
         8: .line 1294
            aload 0 /* this */
            getfield jdk.internal.net.http.Stream$PushedStream.pushReq:Ljdk/internal/net/http/HttpRequestImpl;
            aload 0 /* this */
            getfield jdk.internal.net.http.Stream$PushedStream.exchange:Ljdk/internal/net/http/Exchange;
            aload 1 /* responseHeaders */
            aload 0 /* this */
            invokevirtual jdk.internal.net.http.Stream$PushedStream.connection:()Ljdk/internal/net/http/HttpConnection;
         9: .line 1295
            aload 0 /* this */
            getfield jdk.internal.net.http.Stream$PushedStream.responseCode:I
            getstatic java.net.http.HttpClient$Version.HTTP_2:Ljava/net/http/HttpClient$Version;
            invokespecial jdk.internal.net.http.Response.<init>:(Ljdk/internal/net/http/HttpRequestImpl;Ljdk/internal/net/http/Exchange;Ljava/net/http/HttpHeaders;Ljdk/internal/net/http/HttpConnection;ILjava/net/http/HttpClient$Version;)V
        10: .line 1293
            putfield jdk.internal.net.http.Stream$PushedStream.response:Ljdk/internal/net/http/Response;
        11: .line 1301
            aload 1 /* responseHeaders */
            ldc "content-length"
            invokevirtual java.net.http.HttpHeaders.firstValueAsLong:(Ljava/lang/String;)Ljava/util/OptionalLong;
            pop
        12: .line 1303
            invokestatic jdk.internal.net.http.common.Log.headers:()Z
            ifeq 17
        13: .line 1304
            new java.lang.StringBuilder
            dup
            ldc "RESPONSE HEADERS"
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            astore 2 /* sb */
        start local 2 // java.lang.StringBuilder sb
        14: .line 1305
            aload 2 /* sb */
            ldc " (streamid="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 0 /* this */
            getfield jdk.internal.net.http.Stream$PushedStream.streamid:I
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            ldc "):\n"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            pop
        15: .line 1306
            aload 2 /* sb */
            ldc "    "
            aload 1 /* responseHeaders */
            invokestatic jdk.internal.net.http.common.Log.dumpHeaders:(Ljava/lang/StringBuilder;Ljava/lang/String;Ljava/net/http/HttpHeaders;)V
        16: .line 1307
            aload 2 /* sb */
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            iconst_0
            anewarray java.lang.Object
            invokestatic jdk.internal.net.http.common.Log.logHeaders:(Ljava/lang/String;[Ljava/lang/Object;)V
        end local 2 // java.lang.StringBuilder sb
        17: .line 1310
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.internal.net.http.Stream$PushedStream.rspHeadersConsumer:Ljdk/internal/net/http/Stream$HeadersConsumer;
            invokevirtual jdk.internal.net.http.Stream$HeadersConsumer.reset:()V
        18: .line 1313
            aload 0 /* this */
            aload 0 /* this */
            getfield jdk.internal.net.http.Stream$PushedStream.response:Ljdk/internal/net/http/Response;
            invokevirtual jdk.internal.net.http.Stream$PushedStream.completeResponse:(Ljdk/internal/net/http/Response;)V
        19: .line 1314
            return
        end local 1 // java.net.http.HttpHeaders responseHeaders
        end local 0 // jdk.internal.net.http.Stream$PushedStream this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0   20     0             this  Ljdk/internal/net/http/Stream$PushedStream<TT;>;
            1   20     1  responseHeaders  Ljava/net/http/HttpHeaders;
           14   17     2               sb  Ljava/lang/StringBuilder;

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

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

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

  private static jdk.internal.net.http.Response lambda$3(jdk.internal.net.http.Response);
    descriptor: (Ljdk/internal/net/http/Response;)Ljdk/internal/net/http/Response;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // jdk.internal.net.http.Response r
         0: .line 1237
            aload 0 /* r */
            areturn
        end local 0 // jdk.internal.net.http.Response r
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0     r  Ljdk/internal/net/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.internal.net.http.Stream$PushedStream this
        start local 1 // java.lang.Object v
        start local 2 // java.lang.Throwable t
         0: .line 1249
            aload 0 /* this */
            getfield jdk.internal.net.http.Stream$PushedStream.pushGroup:Ljdk/internal/net/http/PushGroup;
            aload 2 /* t */
            invokevirtual jdk.internal.net.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.internal.net.http.Stream$PushedStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Ljdk/internal/net/http/Stream$PushedStream<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.internal.net.http.Stream$PushedStream this
        start local 1 // java.lang.Void v
         0: .line 1258
            aload 0 /* this */
            aload 0 /* this */
            invokevirtual jdk.internal.net.http.Stream$PushedStream.getPushHandler:()Ljava/net/http/HttpResponse$BodyHandler;
            iconst_0
            aload 0 /* this */
            invokevirtual jdk.internal.net.http.Stream$PushedStream.getExchange:()Ljdk/internal/net/http/Exchange;
            invokevirtual jdk.internal.net.http.Exchange.executor:()Ljava/util/concurrent/Executor;
            invokevirtual jdk.internal.net.http.Stream$PushedStream.readBodyAsync:(Ljava/net/http/HttpResponse$BodyHandler;ZLjava/util/concurrent/Executor;)Ljava/util/concurrent/CompletableFuture;
            areturn
        end local 1 // java.lang.Void v
        end local 0 // jdk.internal.net.http.Stream$PushedStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Ljdk/internal/net/http/Stream$PushedStream<TT;>;
            0    1     1     v  Ljava/lang/Void;

  private void lambda$7(jdk.internal.net.http.Response, java.lang.Object, java.lang.Throwable);
    descriptor: (Ljdk/internal/net/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.internal.net.http.Stream$PushedStream this
        start local 2 // java.lang.Object body
        start local 3 // java.lang.Throwable t
         0: .line 1260
            aload 3 /* t */
            ifnull 3
         1: .line 1261
            aload 0 /* this */
            getfield jdk.internal.net.http.Stream$PushedStream.responseCF:Ljava/util/concurrent/CompletableFuture;
            aload 3 /* t */
            invokevirtual java.util.concurrent.CompletableFuture.completeExceptionally:(Ljava/lang/Throwable;)Z
            pop
         2: .line 1262
            goto 6
         3: .line 1264
      StackMap locals:
      StackMap stack:
            new jdk.internal.net.http.HttpResponseImpl
            dup
            aload 1
            getfield jdk.internal.net.http.Response.request:Ljdk/internal/net/http/HttpRequestImpl;
            aload 1
            aconst_null
            aload 2 /* body */
            aload 0 /* this */
            invokevirtual jdk.internal.net.http.Stream$PushedStream.getExchange:()Ljdk/internal/net/http/Exchange;
            invokespecial jdk.internal.net.http.HttpResponseImpl.<init>:(Ljava/net/http/HttpRequest;Ljdk/internal/net/http/Response;Ljava/net/http/HttpResponse;Ljava/lang/Object;Ljdk/internal/net/http/Exchange;)V
         4: .line 1263
            astore 4 /* resp */
        start local 4 // jdk.internal.net.http.HttpResponseImpl resp
         5: .line 1265
            aload 0 /* this */
            getfield jdk.internal.net.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.internal.net.http.HttpResponseImpl resp
         6: .line 1267
      StackMap locals:
      StackMap stack:
            return
        end local 3 // java.lang.Throwable t
        end local 2 // java.lang.Object body
        end local 0 // jdk.internal.net.http.Stream$PushedStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    7     0  this  Ljdk/internal/net/http/Stream$PushedStream<TT;>;
            0    7     2  body  TT;
            0    7     3     t  Ljava/lang/Throwable;
            5    6     4  resp  Ljdk/internal/net/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 1268
            aconst_null
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
}
Signature: <T:Ljava/lang/Object;>Ljdk/internal/net/http/Stream<TT;>;
SourceFile: "Stream.java"
NestHost: jdk.internal.net.http.Stream
InnerClasses:
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
  public final Version = java.net.http.HttpClient$Version of java.net.http.HttpClient
  public abstract BodyHandler = java.net.http.HttpResponse$BodyHandler of java.net.http.HttpResponse
  private HeadersConsumer = jdk.internal.net.http.Stream$HeadersConsumer of jdk.internal.net.http.Stream
  PushedStream = jdk.internal.net.http.Stream$PushedStream of jdk.internal.net.http.Stream