equal
deleted
inserted
replaced
80 /** The write publisher, responsible for writing the complete request ( both |
80 /** The write publisher, responsible for writing the complete request ( both |
81 * headers and body ( if any ). */ |
81 * headers and body ( if any ). */ |
82 private final Http1Publisher writePublisher = new Http1Publisher(); |
82 private final Http1Publisher writePublisher = new Http1Publisher(); |
83 |
83 |
84 /** Completed when the header have been published, or there is an error */ |
84 /** Completed when the header have been published, or there is an error */ |
85 private volatile CompletableFuture<ExchangeImpl<T>> headersSentCF = new MinimalFuture<>(); |
85 private final CompletableFuture<ExchangeImpl<T>> headersSentCF = new MinimalFuture<>(); |
86 /** Completed when the body has been published, or there is an error */ |
86 /** Completed when the body has been published, or there is an error */ |
87 private volatile CompletableFuture<ExchangeImpl<T>> bodySentCF = new MinimalFuture<>(); |
87 private final CompletableFuture<ExchangeImpl<T>> bodySentCF = new MinimalFuture<>(); |
88 |
88 |
89 /** The subscriber to the request's body published. Maybe null. */ |
89 /** The subscriber to the request's body published. Maybe null. */ |
90 private volatile Http1BodySubscriber bodySubscriber; |
90 private volatile Http1BodySubscriber bodySubscriber; |
91 |
91 |
92 enum State { INITIAL, |
92 enum State { INITIAL, |