It turns out that the problem was something different.
The server was producing chunks with a size of more than the default
value for max-chunk-size (1m). The client aborted with
Failure(akka.http.model.EntityStreamException: HTTP chunk size exceeds
the configured limit of 1048576 bytes). I did no
Thanks a lot. Seems quite obvious now that you explained it.
On Tue, Apr 7, 2015 at 12:25 PM, Akka Team wrote:
> Hi Rüdiger,
>
> You are waiting on the finishFuture of the foreach, but not waiting on the
> internal stream you materialize inside foreach. The finishFuture will
> complete as soon as
Hi Rüdiger,
You are waiting on the finishFuture of the foreach, but not waiting on the
internal stream you materialize inside foreach. The finishFuture will
complete as soon as .run() has been called on the internal stream, which is
probably earlier than the completion of that internal stream itse
Hi all,
I am trying to consume a chunked http stream from the client side. The code
is basically identical to the gist
https://gist.github.com/rklaehn/3f26c3f80e5870831f52#file-client-example
```scala
val printChunksConsumer = Sink.foreach[HttpResponse] { res =>
if(res.status == StatusCod
