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;>;

  private final jdk.incubator.http.Stream<T> parent;
    descriptor: Ljdk/incubator/http/Stream;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljdk/incubator/http/Stream<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.HttpClientImpl, jdk.incubator.http.Http2Connection, jdk.incubator.http.Stream<T>, jdk.incubator.http.Exchange<T>);
    descriptor: (Ljdk/incubator/http/PushGroup;Ljdk/incubator/http/HttpClientImpl;Ljdk/incubator/http/Http2Connection;Ljdk/incubator/http/Stream;Ljdk/incubator/http/Exchange;)V
    flags: (0x0000) 
    Code:
      stack=5, locals=6, args_size=6
        start local 0 // jdk.incubator.http.Stream$PushedStream this
        start local 1 // jdk.incubator.http.PushGroup pushGroup
        start local 2 // jdk.incubator.http.HttpClientImpl client
        start local 3 // jdk.incubator.http.Http2Connection connection
        start local 4 // jdk.incubator.http.Stream parent
        start local 5 // jdk.incubator.http.Exchange pushReq
         0: .line 841
            aload 0 /* this */
            aload 2 /* client */
            aload 3 /* connection */
            aload 5 /* pushReq */
            aconst_null
            invokespecial jdk.incubator.http.Stream.<init>:(Ljdk/incubator/http/HttpClientImpl;Ljdk/incubator/http/Http2Connection;Ljdk/incubator/http/Exchange;Ljdk/incubator/http/WindowController;)V
         1: .line 842
            aload 0 /* this */
            aload 1 /* pushGroup */
            putfield jdk.incubator.http.Stream$PushedStream.pushGroup:Ljdk/incubator/http/PushGroup;
         2: .line 843
            aload 0 /* this */
            aload 5 /* pushReq */
            invokevirtual jdk.incubator.http.Exchange.request:()Ljdk/incubator/http/HttpRequestImpl;
            putfield jdk.incubator.http.Stream$PushedStream.pushReq:Ljdk/incubator/http/HttpRequestImpl;
         3: .line 844
            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 845
            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 846
            aload 0 /* this */
            aload 4 /* parent */
            putfield jdk.incubator.http.Stream$PushedStream.parent:Ljdk/incubator/http/Stream;
         6: .line 847
            return
        end local 5 // jdk.incubator.http.Exchange pushReq
        end local 4 // jdk.incubator.http.Stream parent
        end local 3 // jdk.incubator.http.Http2Connection connection
        end local 2 // jdk.incubator.http.HttpClientImpl client
        end local 1 // jdk.incubator.http.PushGroup pushGroup
        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   pushGroup  Ljdk/incubator/http/PushGroup<TU;TT;>;
            0    7     2      client  Ljdk/incubator/http/HttpClientImpl;
            0    7     3  connection  Ljdk/incubator/http/Http2Connection;
            0    7     4      parent  Ljdk/incubator/http/Stream<TT;>;
            0    7     5     pushReq  Ljdk/incubator/http/Exchange<TT;>;
    Signature: (Ljdk/incubator/http/PushGroup<TU;TT;>;Ljdk/incubator/http/HttpClientImpl;Ljdk/incubator/http/Http2Connection;Ljdk/incubator/http/Stream<TT;>;Ljdk/incubator/http/Exchange<TT;>;)V
    MethodParameters:
            Name  Flags
      pushGroup   
      client      
      connection  
      parent      
      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 850
            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 854
            aload 0 /* this */
            aload 1 /* pushHandler */
            putfield jdk.incubator.http.Stream$PushedStream.pushHandler:Ljdk/incubator/http/HttpResponse$BodyHandler;
         1: .line 855
            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 859
            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 867
            aload 0 /* this */
            invokespecial jdk.incubator.http.Stream.sendBodyAsync:()Ljava/util/concurrent/CompletableFuture;
         1: .line 868
            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 867
            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 873
            aload 0 /* this */
            invokespecial jdk.incubator.http.Stream.sendHeadersAsync:()Ljava/util/concurrent/CompletableFuture;
         1: .line 874
            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 873
            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 879
            aload 0 /* this */
            getfield jdk.incubator.http.Stream$PushedStream.pushCF:Ljava/util/concurrent/CompletableFuture;
            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
            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
         1: .line 880
            aload 1 /* executor */
            ifnull 3
            aload 2 /* cf */
            invokevirtual java.util.concurrent.CompletableFuture.isDone:()Z
            ifne 3
         2: .line 881
            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 */
         3: .line 883
      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    4     0      this  Ljdk/incubator/http/Stream$PushedStream<TU;TT;>;
            0    4     1  executor  Ljava/util/concurrent/Executor;
            1    4     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 892
            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 893
            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 892
            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=3, args_size=2
        start local 0 // jdk.incubator.http.Stream$PushedStream this
        start local 1 // jdk.incubator.http.Response r
         0: .line 898
            aload 1 /* r */
            invokestatic jdk.incubator.http.HttpResponseImpl.logResponse:(Ljdk/incubator/http/Response;)V
         1: .line 899
            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 901
            new jdk.incubator.http.internal.common.MinimalFuture
            dup
            invokespecial jdk.incubator.http.internal.common.MinimalFuture.<init>:()V
            astore 2 /* start */
        start local 2 // java.util.concurrent.CompletableFuture start
         3: .line 902
            aload 2 /* 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$5(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 903
            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$6(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 911
            aload 2 /* 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$7()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 912
            return
        end local 2 // 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     2  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 916
            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 917
            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     

  synchronized void responseReceived();
    descriptor: ()V
    flags: (0x0020) ACC_SYNCHRONIZED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // jdk.incubator.http.Stream$PushedStream this
         0: .line 921
            aload 0 /* this */
            invokespecial jdk.incubator.http.Stream.responseReceived:()V
         1: .line 922
            return
        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;>;

  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 927
            aload 0 /* this */
            getfield jdk.incubator.http.Stream$PushedStream.connection:Ljdk/incubator/http/Http2Connection;
            getfield jdk.incubator.http.Http2Connection.connection:Ljdk/incubator/http/HttpConnection;
            pop
         1: .line 928
            aload 0 /* this */
            aload 0 /* this */
            getfield jdk.incubator.http.Stream$PushedStream.responseHeaders:Ljdk/incubator/http/internal/common/HttpHeadersImpl;
         2: .line 929
            ldc ":status"
            invokevirtual jdk.incubator.http.internal.common.HttpHeadersImpl.firstValueAsLong:(Ljava/lang/String;)Ljava/util/OptionalLong;
         3: .line 930
            ldc -1
            invokevirtual java.util.OptionalLong.orElse:(J)J
            l2i
         4: .line 928
            putfield jdk.incubator.http.Stream$PushedStream.responseCode:I
         5: .line 932
            aload 0 /* this */
            getfield jdk.incubator.http.Stream$PushedStream.responseCode:I
            iconst_m1
            if_icmpne 7
         6: .line 933
            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
         7: .line 936
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            new jdk.incubator.http.Response
            dup
         8: .line 937
            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;
         9: .line 938
            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
        10: .line 936
            putfield jdk.incubator.http.Stream$PushedStream.response:Ljdk/incubator/http/Response;
        11: .line 940
            aload 0 /* this */
            aload 0 /* this */
            getfield jdk.incubator.http.Stream$PushedStream.responseHeaders:Ljdk/incubator/http/internal/common/HttpHeadersImpl;
        12: .line 941
            ldc "content-length"
            invokevirtual jdk.incubator.http.internal.common.HttpHeadersImpl.firstValueAsLong:(Ljava/lang/String;)Ljava/util/OptionalLong;
        13: .line 942
            ldc -1
            invokevirtual java.util.OptionalLong.orElse:(J)J
        14: .line 940
            putfield jdk.incubator.http.Stream$PushedStream.responseContentLen:J
        15: .line 944
            invokestatic jdk.incubator.http.internal.common.Log.headers:()Z
            ifeq 20
        16: .line 945
            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
        17: .line 946
            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
        18: .line 947
            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
        19: .line 948
            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
        20: .line 952
      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
        21: .line 953
            return
        end local 0 // jdk.incubator.http.Stream$PushedStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   22     0  this  Ljdk/incubator/http/Stream$PushedStream<TU;TT;>;
           17   20     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 868
            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 // 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 874
            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 // 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 879
            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 // 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 881
            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 893
            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$5(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 902
            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$6(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=6, 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 904
            aload 3 /* t */
            ifnull 3
         1: .line 905
            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 906
            goto 5
         3: .line 907
      StackMap locals:
      StackMap stack:
            new jdk.incubator.http.HttpResponseImpl
            dup
            aload 1
            getfield jdk.incubator.http.Response.request:Ljdk/incubator/http/HttpRequestImpl;
            aload 1
            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;Ljava/lang/Object;Ljdk/incubator/http/Exchange;)V
            astore 4 /* response */
        start local 4 // jdk.incubator.http.HttpResponseImpl response
         4: .line 908
            aload 0 /* this */
            getfield jdk.incubator.http.Stream$PushedStream.responseCF:Ljava/util/concurrent/CompletableFuture;
            aload 4 /* response */
            invokevirtual java.util.concurrent.CompletableFuture.complete:(Ljava/lang/Object;)Z
            pop
        end local 4 // jdk.incubator.http.HttpResponseImpl response
         5: .line 910
      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    6     0      this  Ljdk/incubator/http/Stream$PushedStream<TU;TT;>;
            0    6     2      body  TT;
            0    6     3         t  Ljava/lang/Throwable;
            4    5     4  response  Ljdk/incubator/http/HttpResponseImpl<TT;>;

  private static java.lang.Void lambda$7();
    descriptor: ()Ljava/lang/Void;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 911
            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