diff --git a/docs/src/test/java/docs/http/javadsl/server/HttpServerExampleDocTest.java b/docs/src/test/java/docs/http/javadsl/server/HttpServerExampleDocTest.java index b662a168a..8ac0670cd 100644 --- a/docs/src/test/java/docs/http/javadsl/server/HttpServerExampleDocTest.java +++ b/docs/src/test/java/docs/http/javadsl/server/HttpServerExampleDocTest.java @@ -51,7 +51,7 @@ public static void bindingExample() throws Exception { Materializer materializer = Materializer.createMaterializer(system); Source> serverSource = - Http.get(system).bind(ConnectHttp.toHost("localhost", 8080)); + Http.get(system).newServerAt("localhost", 8080).connectionSource(); CompletionStage serverBindingFuture = serverSource @@ -73,7 +73,7 @@ public static void bindingFailureExample() throws Exception { Materializer materializer = Materializer.createMaterializer(system); Source> serverSource = - Http.get(system).bind(ConnectHttp.toHost("localhost", 80)); + Http.get(system).newServerAt("localhost", 80).connectionSource(); CompletionStage serverBindingFuture = serverSource @@ -101,7 +101,7 @@ public static void connectionSourceFailureExample() throws Exception { Materializer materializer = Materializer.createMaterializer(system); Source> serverSource = - Http.get(system).bind(ConnectHttp.toHost("localhost", 8080)); + Http.get(system).newServerAt("localhost", 8080).connectionSource(); Flow failureDetection = Flow.of(IncomingConnection.class) @@ -137,7 +137,7 @@ public static void connectionStreamFailureExample() throws Exception { Materializer materializer = Materializer.createMaterializer(system); Source> serverSource = - Http.get(system).bind(ConnectHttp.toHost("localhost", 8080)); + Http.get(system).newServerAt("localhost", 8080).connectionSource(); Flow failureDetection = Flow.of(HttpRequest.class) @@ -186,7 +186,7 @@ public static void fullServerExample() throws Exception { final Materializer materializer = Materializer.createMaterializer(system); Source> serverSource = - Http.get(system).bind(ConnectHttp.toHost("localhost", 8080)); + Http.get(system).newServerAt("localhost", 8080).connectionSource(); // #request-handler final Function requestHandler = @@ -379,10 +379,8 @@ public static void gracefulTerminationExample() throws Exception { CompletionStage binding = Http.get(system) - .bindAndHandle( - Directives.complete("Hello world!").flow(system, materializer), - ConnectHttp.toHost("localhost", 8080), - materializer); + .newServerAt("localhost", 8080) + .bindFlow(Directives.complete("Hello world!").flow(system, materializer)); ServerBinding serverBinding = binding.toCompletableFuture().get(3, TimeUnit.SECONDS);