pekko/akka-docs-dev/rst/scala/code/docs/http/HttpServerExampleSpec.scala

/*
 * Copyright (C) 2009-2014 Typesafe Inc. <http://www.typesafe.com>
 */

package docs.http

import akka.actor.ActorSystem
import akka.http.model._
import akka.stream.scaladsl._
import akka.stream.testkit.AkkaSpec
import scala.concurrent.Future
import akka.http.Http

class HttpServerExampleSpec
  extends AkkaSpec("akka.actor.default-mailbox.mailbox-type = akka.dispatch.UnboundedMailbox") {
  def ActorSystem(): ActorSystem = system

  "binding example" in {
    //#bind-example
    import akka.http.Http
    import akka.stream.ActorFlowMaterializer

    implicit val system = ActorSystem()
    implicit val materializer = ActorFlowMaterializer()

    val serverSource: Source[Http.IncomingConnection, Future[Http.ServerBinding]] =
      Http(system).bind(interface = "localhost", port = 8080)
    val bindingFuture: Future[Http.ServerBinding] = serverSource.to(Sink.foreach { connection =>
      // foreach materializes the source
      println("Accepted new connection from " + connection.remoteAddress)
      // ... and then actually handle the connection
    }).run()
    //#bind-example
  }

  "full-server-example" in {
    import akka.http.Http
    import akka.stream.ActorFlowMaterializer

    implicit val system = ActorSystem()
    implicit val materializer = ActorFlowMaterializer()

    val serverSource = Http(system).bind(interface = "localhost", port = 8080)

    //#full-server-example
    import akka.http.model.HttpMethods._
    import akka.stream.scaladsl.{ Flow, Sink }

    val requestHandler: HttpRequest => HttpResponse = {
      case HttpRequest(GET, Uri.Path("/"), _, _, _) =>
        HttpResponse(
          entity = HttpEntity(MediaTypes.`text/html`,
            "<html><body>Hello world!</body></html>"))

      case HttpRequest(GET, Uri.Path("/ping"), _, _, _) =>
        HttpResponse(entity = "PONG!")

      case HttpRequest(GET, Uri.Path("/crash"), _, _, _) =>
        sys.error("BOOM!")

      case _: HttpRequest =>
        HttpResponse(404, entity = "Unknown resource!")
    }

    val bindingFuture: Future[Http.ServerBinding] = serverSource.to(Sink.foreach { connection =>
      println("Accepted new connection from " + connection.remoteAddress)

      connection handleWithSyncHandler requestHandler
      // this is equivalent to
      // connection handleWith { Flow[HttpRequest] map requestHandler }
    }).run()
    //#full-server-example
  }
}
=doc first parts of HTTP model documentation 2014-06-16 23:09:51 +02:00			`/*`
			`* Copyright (C) 2009-2014 Typesafe Inc. <http://www.typesafe.com>`
			`*/`

			`package docs.http`

			`import akka.actor.ActorSystem`
!str #15121 MaterializerSettings now uses a config object Resolves #15121 2014-08-26 09:03:48 +02:00			`import akka.http.model._`
=doc #16989 update http bind documentation 2015-03-26 21:38:27 +02:00			`import akka.stream.scaladsl._`
!str #15121 MaterializerSettings now uses a config object Resolves #15121 2014-08-26 09:03:48 +02:00			`import akka.stream.testkit.AkkaSpec`
=doc #16989 update http bind documentation 2015-03-26 21:38:27 +02:00			`import scala.concurrent.Future`
			`import akka.http.Http`
=doc first parts of HTTP model documentation 2014-06-16 23:09:51 +02:00
			`class HttpServerExampleSpec`
			`extends AkkaSpec("akka.actor.default-mailbox.mailbox-type = akka.dispatch.UnboundedMailbox") {`
			`def ActorSystem(): ActorSystem = system`

			`"binding example" in {`
			`//#bind-example`
			`import akka.http.Http`
!str #15851 Rename FlowMaterializer and settings * FlowMaterializer is now the actor independent interface * ActorFlowMaterializer is the actor based interface * MaterializerSettings renamed to ActorFlowMaterializerSettings * impl.ActorBasedFlowMaterializer renamed to impl.ActorFlowMaterializerImpl * Optimizations included in ActorFlowMaterializerSettings * Note that http is using FlowMaterializer in api, but I suspect that it will currently only run with a ActorFlowMaterializer 2015-01-27 18:29:20 +01:00			`import akka.stream.ActorFlowMaterializer`
=doc first parts of HTTP model documentation 2014-06-16 23:09:51 +02:00
			`implicit val system = ActorSystem()`
!str #15851 Rename FlowMaterializer and settings * FlowMaterializer is now the actor independent interface * ActorFlowMaterializer is the actor based interface * MaterializerSettings renamed to ActorFlowMaterializerSettings * impl.ActorBasedFlowMaterializer renamed to impl.ActorFlowMaterializerImpl * Optimizations included in ActorFlowMaterializerSettings * Note that http is using FlowMaterializer in api, but I suspect that it will currently only run with a ActorFlowMaterializer 2015-01-27 18:29:20 +01:00			`implicit val materializer = ActorFlowMaterializer()`
=doc first parts of HTTP model documentation 2014-06-16 23:09:51 +02:00
=doc #16989 update http bind documentation 2015-03-26 21:38:27 +02:00			`val serverSource: Source[Http.IncomingConnection, Future[Http.ServerBinding]] =`
			`Http(system).bind(interface = "localhost", port = 8080)`
			`val bindingFuture: Future[Http.ServerBinding] = serverSource.to(Sink.foreach { connection =>`
			`// foreach materializes the source`
!htc #16162 upgrade HTTP-level APIs to end-user style 2014-11-27 14:00:39 +01:00			`println("Accepted new connection from " + connection.remoteAddress)`
!str #16902: Unify stream internal representation also =str #16912: Fix StreamTcpSpec flakiness 2015-01-28 14:19:50 +01:00			`// ... and then actually handle the connection`
=doc #16989 update http bind documentation 2015-03-26 21:38:27 +02:00			`}).run()`
=doc first parts of HTTP model documentation 2014-06-16 23:09:51 +02:00			`//#bind-example`
			`}`
+str,htc #16071, #16072 New Stream Tcp and Http API * StreamTcp and Http extensions now return Flows and Sources that can be materialized later * Flow can now be completed with another flow to be turned into a runnable flow 2014-11-28 10:41:57 +01:00
=doc first parts of HTTP model documentation 2014-06-16 23:09:51 +02:00			`"full-server-example" in {`
			`import akka.http.Http`
!str #15851 Rename FlowMaterializer and settings * FlowMaterializer is now the actor independent interface * ActorFlowMaterializer is the actor based interface * MaterializerSettings renamed to ActorFlowMaterializerSettings * impl.ActorBasedFlowMaterializer renamed to impl.ActorFlowMaterializerImpl * Optimizations included in ActorFlowMaterializerSettings * Note that http is using FlowMaterializer in api, but I suspect that it will currently only run with a ActorFlowMaterializer 2015-01-27 18:29:20 +01:00			`import akka.stream.ActorFlowMaterializer`
=doc first parts of HTTP model documentation 2014-06-16 23:09:51 +02:00
			`implicit val system = ActorSystem()`
!str #15851 Rename FlowMaterializer and settings * FlowMaterializer is now the actor independent interface * ActorFlowMaterializer is the actor based interface * MaterializerSettings renamed to ActorFlowMaterializerSettings * impl.ActorBasedFlowMaterializer renamed to impl.ActorFlowMaterializerImpl * Optimizations included in ActorFlowMaterializerSettings * Note that http is using FlowMaterializer in api, but I suspect that it will currently only run with a ActorFlowMaterializer 2015-01-27 18:29:20 +01:00			`implicit val materializer = ActorFlowMaterializer()`
=doc first parts of HTTP model documentation 2014-06-16 23:09:51 +02:00
!str #16902: Unify stream internal representation also =str #16912: Fix StreamTcpSpec flakiness 2015-01-28 14:19:50 +01:00			`val serverSource = Http(system).bind(interface = "localhost", port = 8080)`
=doc first parts of HTTP model documentation 2014-06-16 23:09:51 +02:00
			`//#full-server-example`
!str #15121 MaterializerSettings now uses a config object Resolves #15121 2014-08-26 09:03:48 +02:00			`import akka.http.model.HttpMethods._`
!str #16902: Unify stream internal representation also =str #16912: Fix StreamTcpSpec flakiness 2015-01-28 14:19:50 +01:00			`import akka.stream.scaladsl.{ Flow, Sink }`
=doc first parts of HTTP model documentation 2014-06-16 23:09:51 +02:00
+doc #16549 StreamTCP docs 2014-12-22 16:18:26 +01:00			`val requestHandler: HttpRequest => HttpResponse = {`
			`case HttpRequest(GET, Uri.Path("/"), _, _, _) =>`
=doc first parts of HTTP model documentation 2014-06-16 23:09:51 +02:00			`HttpResponse(`
			entity = HttpEntity(MediaTypes.`text/html`,
+pro,hco,par Make sure that things build on both 2.10 and 2.11 2014-06-25 14:32:29 +02:00			`"<html><body>Hello world!</body></html>"))`
=doc first parts of HTTP model documentation 2014-06-16 23:09:51 +02:00
=doc #16989 update http bind documentation 2015-03-26 21:38:27 +02:00			`case HttpRequest(GET, Uri.Path("/ping"), _, _, _) =>`
			`HttpResponse(entity = "PONG!")`

			`case HttpRequest(GET, Uri.Path("/crash"), _, _, _) =>`
			`sys.error("BOOM!")`

			`case _: HttpRequest =>`
			`HttpResponse(404, entity = "Unknown resource!")`
=doc first parts of HTTP model documentation 2014-06-16 23:09:51 +02:00			`}`

=doc #16989 update http bind documentation 2015-03-26 21:38:27 +02:00			`val bindingFuture: Future[Http.ServerBinding] = serverSource.to(Sink.foreach { connection =>`
!htc #16162 upgrade HTTP-level APIs to end-user style 2014-11-27 14:00:39 +01:00			`println("Accepted new connection from " + connection.remoteAddress)`
+str,htc #16071, #16072 New Stream Tcp and Http API * StreamTcp and Http extensions now return Flows and Sources that can be materialized later * Flow can now be completed with another flow to be turned into a runnable flow 2014-11-28 10:41:57 +01:00
=doc a first set of new and imported documentation for akka-http 2014-12-18 09:25:33 +01:00			`connection handleWithSyncHandler requestHandler`
			`// this is equivalent to`
			`// connection handleWith { Flow[HttpRequest] map requestHandler }`
!str #16902: Unify stream internal representation also =str #16912: Fix StreamTcpSpec flakiness 2015-01-28 14:19:50 +01:00			`}).run()`
=doc first parts of HTTP model documentation 2014-06-16 23:09:51 +02:00			`//#full-server-example`
			`}`
			`}`