我有以下代码:
val serverSource = Http().bind("localhost", 8080)
val connectionSink = Sink.foreach[IncomingConnection] {
connection => println(s"Accepted incoming connection from ${connection.remoteAddress}")
}
val serverBindingFuture = serverSource.to(connectionSink).run()
serverBindingFuture.onComplete {
case Success(binding) => {
println("Server binding successful")
binding.terminate(10 seconds)
}
case Failure(ex) => println(s"Server binding failed $ex")
}
如摘要所示,我将在10秒钟后终止服务器绑定。因此,我希望如果在此期限到期之前发送请求,我应该得到消息“接受的来自...的传入连接”。
但是我发现我总是收到'无法访问此站点'的消息,并且从不打印消息。
如摘要所示,我将在10秒钟后终止服务器绑定。因此,我希望如果在此期限到期之前发送请求,我应该得到消息“接受的来自...的传入连接”。