#19046 replace system.{shutdown => terminate}
This commit is contained in:
parent
1ef35d907f
commit
3140e72265
57 changed files with 67 additions and 67 deletions
|
|
@ -78,7 +78,7 @@ class IntroSpec extends TypedSpec {
|
|||
def `must say hello`(): Unit = {
|
||||
//#hello-world
|
||||
import HelloWorld._
|
||||
// using global pool since we want to run tasks after system shutdown
|
||||
// using global pool since we want to run tasks after system.terminate
|
||||
import scala.concurrent.ExecutionContext.Implicits.global
|
||||
|
||||
val system: ActorSystem[Greet] = ActorSystem("hello", Props(greeter))
|
||||
|
|
|
|||
|
|
@ -281,7 +281,7 @@ class HttpServerExampleSpec extends WordSpec with Matchers {
|
|||
Console.readLine() // for the future transformations
|
||||
bindingFuture
|
||||
.flatMap(_.unbind()) // trigger unbinding from the port
|
||||
.onComplete(_ ⇒ system.shutdown()) // and shutdown when done
|
||||
.onComplete(_ ⇒ system.terminate()) // and shutdown when done
|
||||
}
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -62,7 +62,7 @@ class WebsocketExampleSpec extends WordSpec with Matchers {
|
|||
import system.dispatcher // for the future transformations
|
||||
bindingFuture
|
||||
.flatMap(_.unbind()) // trigger unbinding from the port
|
||||
.onComplete(_ ⇒ system.shutdown()) // and shutdown when done
|
||||
.onComplete(_ ⇒ system.terminate()) // and shutdown when done
|
||||
}
|
||||
"routing-example" in {
|
||||
pending // compile-time only test
|
||||
|
|
@ -104,6 +104,6 @@ class WebsocketExampleSpec extends WordSpec with Matchers {
|
|||
import system.dispatcher // for the future transformations
|
||||
bindingFuture
|
||||
.flatMap(_.unbind()) // trigger unbinding from the port
|
||||
.onComplete(_ ⇒ system.shutdown()) // and shutdown when done
|
||||
.onComplete(_ ⇒ system.terminate()) // and shutdown when done
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue