Hi, make sure you catch all exceptions, for example if the unmarshaller
dies you still have to consume the entity. For example by putting a
recoverWith case on the unmarshaller's future something like this:
Unmarshal(response.entity)
.to[T]
.recoverWith {
case reason: Throwable =>
val result = Future.failed(reason)
if (response.status.allowsEntity) {
response.discardEntityBytes()
.future()
.flatMap(_ => result)
.recoverWith { case _: IllegalStateException => result } // If
the entity was already consumed by a failing unmarshaller
} else {
result
}
}
vigoo
2017. június 19., hétfő 18:05:46 UTC+2 időpontban Erwan Loisant a
következőt írta:
>
> Hi,
>
> I'm migrating a big project from dispatch to Akka http for client calls.
> I'm having an issues in our tests, we're sending a lot of calls and at some
> point I'm not getting any response, i.e. with the request-level API the
> Future never completes.
>
> From what I have read, that can happen when we don't consume the entity
> bytes so I'm making sure we always either Unmarshal the entity, or call
> response.discardEntityBytes.
>
> What could cause that? Do you confirm that Unmarshal will consume the
> entity bytes and free a connection? Is there something else I need to be
> careful in my calls? Or is there a way I can monitor the request pools
> created by Akka http to debug my code?
>
>
> Thank you!
>
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
