https://github.com/akka/akka-http/issues/907

AbruptTerminationExceptionExample.scala

import akka.actor.ActorSystem
import akka.event.Logging
import akka.http.scaladsl.Http
import akka.http.scaladsl.client.RequestBuilding._
import akka.http.scaladsl.unmarshalling.Unmarshal
import akka.stream.ActorMaterializer

import scala.concurrent.Await
import scala.concurrent.duration.Duration.Inf

object MainError {
  private implicit val system = ActorSystem()
  private implicit val materializer = ActorMaterializer()
  private implicit val executionContext = system.dispatcher
  val log = Logging(system, getClass)

  def main(args: Array[String]): Unit = {
    try {
      val request = Get("https://example.com")
      val bytesFuture = Http(system).singleRequest(request).flatMap(response => {
        Unmarshal(response.entity.withoutSizeLimit()).to[Array[Byte]]
      })
      val bytes = Await.result(bytesFuture, Inf)
      log.info(s"Size ${bytes.length}")
    } catch {
      case err: Throwable => log.error(err.getMessage)
    } finally {
      Await.ready(Http().shutdownAllConnectionPools(), Inf)
      Await.ready(system.terminate(), Inf)
    }
  }
}