akka http client system.shutdown() создает ошибку исходящего потока запросов (akka.stream.AbruptTerminationException) при использовании https

Привет, следующий код работает, как и ожидалось.

implicit val system = ActorSystem()
implicit val materializer = ActorMaterializer()

import system.dispatcher

val request = HttpRequest(uri = "http://www.google.com")

Http.get(system).singleRequest(request).map(_.entity.dataBytes.runWith(Sink.ignore))
  .onComplete { _ =>
    println("shutting down actor system...")
    system.terminate()
  }

Однако если я изменю http://www.google.com на https://www.google.com следующим образом:

implicit val system = ActorSystem()
implicit val materializer = ActorMaterializer()

import system.dispatcher

val request = HttpRequest(uri = "https://www.google.com")

Http.get(system).singleRequest(request).map(_.entity.dataBytes.runWith(Sink.ignore))
  .onComplete { _ =>
    println("shutting down actor system...")
    system.terminate()
  }

Я получаю следующее сообщение об ошибке:

shutting down actor system...
[ERROR] [02/11/2017 13:13:08.929] [default-akka.actor.default-dispatcher-4] [akka.actor.ActorSystemImpl(default)] Outgoing request stream error (akka.stream.AbruptTerminationException)

Кто-нибудь знает, почему https выдает вышеуказанную ошибку и как ее исправить?


person Xzer    schedule 11.02.2017    source источник


Ответы (1)


По-видимому, это известная проблема, см. следующие билеты:

Ошибка кажется безобидной.

person blouerat    schedule 20.02.2017