96 volatile int numberOfRedirects = 0; |
96 volatile int numberOfRedirects = 0; |
97 |
97 |
98 /** |
98 /** |
99 * MultiExchange with one final response. |
99 * MultiExchange with one final response. |
100 */ |
100 */ |
101 MultiExchange(HttpRequest req, |
101 MultiExchange(HttpRequest userRequest, |
|
102 HttpRequestImpl requestImpl, |
102 HttpClientImpl client, |
103 HttpClientImpl client, |
103 HttpResponse.BodyHandler<T> responseHandler, |
104 HttpResponse.BodyHandler<T> responseHandler, |
104 AccessControlContext acc) { |
105 AccessControlContext acc) { |
105 this.previous = null; |
106 this.previous = null; |
106 this.userRequest = req; |
107 this.userRequest = userRequest; |
107 this.request = new HttpRequestImpl(req, acc); |
108 this.request = requestImpl; |
108 this.currentreq = request; |
109 this.currentreq = request; |
109 this.client = client; |
110 this.client = client; |
110 this.filters = client.filterChain(); |
111 this.filters = client.filterChain(); |
111 this.acc = acc; |
112 this.acc = acc; |
112 this.executor = client.theExecutor(); |
113 this.executor = client.theExecutor(); |
122 } |
123 } |
123 |
124 |
124 /** |
125 /** |
125 * MultiExchange with multiple responses (HTTP/2 server pushes). |
126 * MultiExchange with multiple responses (HTTP/2 server pushes). |
126 */ |
127 */ |
127 MultiExchange(HttpRequest req, |
128 MultiExchange(HttpRequest userRequest, |
|
129 HttpRequestImpl requestImpl, |
128 HttpClientImpl client, |
130 HttpClientImpl client, |
129 HttpResponse.MultiSubscriber<U, T> multiResponseSubscriber, |
131 HttpResponse.MultiSubscriber<U, T> multiResponseSubscriber, |
130 AccessControlContext acc) { |
132 AccessControlContext acc) { |
131 this.previous = null; |
133 this.previous = null; |
132 this.userRequest = req; |
134 this.userRequest = userRequest; |
133 this.request = new HttpRequestImpl(req, acc); |
135 this.request = requestImpl; |
134 this.currentreq = request; |
136 this.currentreq = request; |
135 this.client = client; |
137 this.client = client; |
136 this.filters = client.filterChain(); |
138 this.filters = client.filterChain(); |
137 this.acc = acc; |
139 this.acc = acc; |
138 this.executor = client.theExecutor(); |
140 this.executor = client.theExecutor(); |