raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

=htc #17129 Preliminary fix until this is fixed with the new features from #16168

Browse source
This commit is contained in:
Johannes Rudolph 2015-04-21 14:32:31 +02:00
parent 7b72fca3c2
commit d67b5823e6
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-http-core/src/main/scala/akka/http/Http.scala
View file

@ -40,10 +40,10 @@ class HttpExt(config: Config)(implicit system: ActorSystem) extends akka.actor.E
val connections: Source[StreamTcp.IncomingConnection, Future[StreamTcp.ServerBinding]] = val connections: Source[StreamTcp.IncomingConnection, Future[StreamTcp.ServerBinding]] =
StreamTcp().bind(endpoint, backlog, options, effectiveSettings.timeouts.idleTimeout) StreamTcp().bind(endpoint, backlog, options, effectiveSettings.timeouts.idleTimeout)
val layer = serverLayer(effectiveSettings, log)
connections.map { connections.map {
case StreamTcp.IncomingConnection(localAddress, remoteAddress, flow) ⇒ case StreamTcp.IncomingConnection(localAddress, remoteAddress, flow) ⇒
val layer = serverLayer(effectiveSettings, log)
IncomingConnection(localAddress, remoteAddress, layer join flow) IncomingConnection(localAddress, remoteAddress, layer join flow)
}.mapMaterialized { tcpBindingFuture ⇒ }.mapMaterialized { tcpBindingFuture ⇒
import system.dispatcher import system.dispatcher