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

=str #18763 remove unused parameter in PoolConductor

Browse source
This commit is contained in:
Konrad Malawski 2015-10-22 15:29:12 +02:00
parent 630bd948d5
commit 99a9c5964e
2 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-http-core/src/main/scala/akka/http/impl/engine/client/PoolConductor.scala
View file

@ -64,12 +64,12 @@ private object PoolConductor {
+---------+
*/
def apply(slotCount: Int, maxRetries: Int, pipeliningLimit: Int, log: LoggingAdapter): Graph[Ports, Any] =
def apply(slotCount: Int, pipeliningLimit: Int, log: LoggingAdapter): Graph[Ports, Any] =
FlowGraph.create() { implicit b ⇒
import FlowGraph.Implicits._
val retryMerge = b.add(MergePreferred[RequestContext](1, eagerClose = true))
val slotSelector = b.add(new SlotSelector(slotCount, maxRetries, pipeliningLimit, log))
val slotSelector = b.add(new SlotSelector(slotCount, pipeliningLimit, log))
val route = b.add(new Route(slotCount))
val retrySplit = b.add(Broadcast[RawSlotEvent](2))
val flatten = Flow[RawSlotEvent].mapAsyncUnordered(slotCount) {
@ -106,7 +106,7 @@ private object PoolConductor {
private case class Busy(openRequests: Int) extends SlotState { require(openRequests > 0) }
private object Busy extends Busy(1)
private class SlotSelector(slotCount: Int, maxRetries: Int, pipeliningLimit: Int, log: LoggingAdapter)
private class SlotSelector(slotCount: Int, pipeliningLimit: Int, log: LoggingAdapter)
extends GraphStage[FanInShape2[RequestContext, SlotEvent, SwitchCommand]] {
private val ctxIn = Inlet[RequestContext]("requestContext")

2
akka-http-core/src/main/scala/akka/http/impl/engine/client/PoolFlow.scala
View file

@ -74,7 +74,7 @@ private object PoolFlow {
import settings._
import FlowGraph.Implicits._
val conductor = b.add(PoolConductor(maxConnections, maxRetries, pipeliningLimit, log))
val conductor = b.add(PoolConductor(maxConnections, pipeliningLimit, log))
val slots = Vector
.tabulate(maxConnections)(PoolSlot(_, connectionFlow, remoteAddress, settings))
.map(b.add(_))