client {
request-timeout = 600 s
parsing {
max-content-length = 2g
max-chunk-size = 10m
}
}
Test Code:
class DownloadManager extends Actor {
import context.dispatcher
private val pipeline: HttpRequest => Future[HttpResponse] = sendReceive
override def preStart(): Unit = {
val response = pipeline(Get(url)).map(_.right) recover recoverFuture
response onComplete {
case Success(r) => println(s"Response: $r")
case Failure(ex) => println(ex, "ResponseFail")
}
}
def receive: PartialFunction[Any, Unit] = {
case other => log.error(s"Received: $other")
}
}