2017-02-11 1 views
3

こんにちは、次のコードは期待どおり動作します。私は次のようにhttps://www.google.comhttp://www.google.comを変更した場合akka httpクライアントsystem.shutdown()を生成します。httpsを使用すると、 "発信要求ストリームエラー(akka.stream.AbruptTerminationException)"が発生します

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() 
    } 

はしかし、:

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() 
    } 

私は、次のエラーメッセージが表示されます:httpsのエラーの上に生成し、どのようにすることができますなぜ

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) 

誰もが知っています私が直します?

答えて

4

これは、次のチケットを参照してください、明らかに既知の問題です:

エラーが無害と思われます。

関連する問題