=doc shuffle test files around to proper packages

2015-07-17 15:30:14 +02:00 · 2015-07-17 15:30:14 +02:00 · d50c0e3426
commit d50c0e3426
parent b2c38444b3
9 changed files with 12 additions and 12 deletions
--- a/akka-docs-dev/rst/java/code/docs/http/javadsl/server/HttpServerExampleDocTest.java
+++ b/akka-docs-dev/rst/java/code/docs/http/javadsl/server/HttpServerExampleDocTest.java
@ -0,0 +1,121 @@
+/*
+ * Copyright (C) 2009-2015 Typesafe Inc. <http://www.typesafe.com>
+ */
+
+package docs.http.javadsl.server;
+
+import akka.actor.ActorSystem;
+import akka.http.impl.util.Util;
+import akka.http.javadsl.Http;
+import akka.http.javadsl.IncomingConnection;
+import akka.http.javadsl.ServerBinding;
+import akka.http.javadsl.model.*;
+import akka.http.javadsl.model.ws.Websocket;
+import akka.japi.function.Function;
+import akka.japi.function.Procedure;
+import akka.stream.ActorMaterializer;
+import akka.stream.Materializer;
+import akka.stream.javadsl.Flow;
+import akka.stream.javadsl.Sink;
+import akka.stream.javadsl.Source;
+import org.junit.Test;
+import scala.Function1;
+import scala.concurrent.Await;
+import scala.concurrent.Future;
+import scala.concurrent.duration.FiniteDuration;
+
+import java.io.BufferedReader;
+import java.io.InputStreamReader;
+import java.util.concurrent.TimeUnit;
+
+public class HttpServerExampleDocTest {
+    public static void bindingExample() {
+        //#binding-example
+        ActorSystem system = ActorSystem.create();
+        Materializer materializer = ActorMaterializer.create(system);
+
+        Source<IncomingConnection, Future<ServerBinding>> serverSource =
+            Http.get(system).bind("localhost", 8080, materializer);
+
+        Future<ServerBinding> serverBindingFuture =
+            serverSource.to(Sink.foreach(
+                new Procedure<IncomingConnection>() {
+                    @Override
+                    public void apply(IncomingConnection connection) throws Exception {
+                        System.out.println("Accepted new connection from " + connection.remoteAddress());
+                        // ... and then actually handle the connection
+                    }
+                })).run(materializer);
+        //#binding-example
+    }
+    public static void fullServerExample() throws Exception {
+        //#full-server-example
+            ActorSystem system = ActorSystem.create();
+        //#full-server-example
+        try {
+            //#full-server-example
+            final Materializer materializer = ActorMaterializer.create(system);
+
+            Source<IncomingConnection, Future<ServerBinding>> serverSource =
+                    Http.get(system).bind("localhost", 8080, materializer);
+
+            //#request-handler
+            final Function<HttpRequest, HttpResponse> requestHandler =
+                new Function<HttpRequest, HttpResponse>() {
+                    private final HttpResponse NOT_FOUND =
+                        HttpResponse.create()
+                            .withStatus(404)
+                            .withEntity("Unknown resource!");
+
+
+                    @Override
+                    public HttpResponse apply(HttpRequest request) throws Exception {
+                        Uri uri = request.getUri();
+                        if (request.method() == HttpMethods.GET) {
+                            if (uri.path().equals("/"))
+                                return
+                                    HttpResponse.create()
+                                        .withEntity(MediaTypes.TEXT_HTML.toContentType(),
+                                            "<html><body>Hello world!</body></html>");
+                            else if (uri.path().equals("/hello")) {
+                                String name = Util.getOrElse(uri.parameter("name"), "Mister X");
+
+                                return
+                                    HttpResponse.create()
+                                        .withEntity("Hello " + name + "!");
+                            }
+                            else if (uri.path().equals("/ping"))
+                                return HttpResponse.create().withEntity("PONG!");
+                            else
+                                return NOT_FOUND;
+                        }
+                        else return NOT_FOUND;
+                    }
+                };
+            //#request-handler
+
+            Future<ServerBinding> serverBindingFuture =
+                serverSource.to(Sink.foreach(
+                    new Procedure<IncomingConnection>() {
+                        @Override
+                        public void apply(IncomingConnection connection) throws Exception {
+                            System.out.println("Accepted new connection from " + connection.remoteAddress());
+
+                            connection.handleWithSyncHandler(requestHandler, materializer);
+                            // this is equivalent to
+                            //connection.handleWith(Flow.of(HttpRequest.class).map(requestHandler), materializer);
+                        }
+                    })).run(materializer);
+            //#full-server-example
+
+            Await.result(serverBindingFuture, new FiniteDuration(1, TimeUnit.SECONDS)); // will throw if binding fails
+            System.out.println("Press ENTER to stop.");
+            new BufferedReader(new InputStreamReader(System.in)).readLine();
+        } finally {
+            system.shutdown();
+        }
+    }
+    public static void main(String[] args) throws Exception {
+        fullServerExample();
+    }
+}