Skip to content

Commit 24fa654

Browse files
[client] Don't close connections when HttpObjectAggregator is on the pipeline
1 parent d35d5bb commit 24fa654

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
@@ -195,13 +195,9 @@
195195
(instance? FullHttpResponse msg)
196196
(let [^FullHttpResponse rsp msg
197197
content (.content rsp)
198-
c (d/deferred)
199-
s (netty/buffered-source (netty/channel ctx) #(alength ^bytes %) buffer-capacity)]
200-
(s/on-closed s #(d/success! c true))
201-
(s/put! s (netty/buf->array content))
198+
body (netty/buf->array content)]
202199
(netty/release content)
203-
(handle-response rsp c s)
204-
(s/close! s))
200+
(handle-response rsp (d/success-deferred false) body))
205201

206202
(instance? HttpResponse msg)
207203
(let [rsp msg]

0 commit comments

Comments
 (0)