Skip to content

Commit b994040

Browse files
authored
Merge pull request #483 from alexander-yakushev/client-aggregator
[client] Don't close connections when HttpObjectAggregator is on the pipeline
2 parents ca00d66 + 24fa654 commit b994040

File tree

1 file changed

+2
-6
lines changed

1 file changed

+2
-6
lines changed

src/aleph/http/client.clj

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -203,13 +203,9 @@
203203
(instance? FullHttpResponse msg)
204204
(let [^FullHttpResponse rsp msg
205205
content (.content rsp)
206-
c (d/deferred)
207-
s (netty/buffered-source (netty/channel ctx) #(alength ^bytes %) buffer-capacity)]
208-
(s/on-closed s #(d/success! c true))
209-
(s/put! s (netty/buf->array content))
206+
body (netty/buf->array content)]
210207
(netty/release content)
211-
(handle-response rsp c s)
212-
(s/close! s))
208+
(handle-response rsp (d/success-deferred false) body))
213209

214210
(instance? HttpResponse msg)
215211
(let [rsp msg]

0 commit comments

Comments
 (0)