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

+str Add FanInShape1N

Browse source
This commit is contained in:
Mathias 2015-03-12 16:31:07 +01:00
parent 3b23d84788
commit e02b28fc36
1 changed files with 15 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

15
akka-stream/src/main/boilerplate/akka/stream/FanInShape.scala.template
View file

@ -57,6 +57,21 @@ class UniformFanInShape[T, O](val n: Int, _init: FanInShape.Init[O]) extends Fan
def in(n: Int): Inlet[T] = inArray(n)
}
class FanInShape1N[T0, T1, O](val n: Int, _init: FanInShape.Init[O]) extends FanInShape[O](_init) {
def this(n: Int) = this(n, FanInShape.Name("FanInShape1N"))
def this(n: Int, name: String) = this(n, FanInShape.Name(name))
def this(outlet: Outlet[O], in0: Inlet[T0], inlets1: Array[Inlet[T1]]) = this(inlets1.length, FanInShape.Ports(outlet, in0 :: inlets1.toList))
override protected def construct(init: FanInShape.Init[O]): FanInShape[O] = new FanInShape1N(n, init)
override def deepCopy(): FanInShape1N[T0, T1, O] = super.deepCopy().asInstanceOf[FanInShape1N[T0, T1, O]]
val in0 = newInlet[T0]("in0")
val in1Seq: immutable.IndexedSeq[Inlet[T1]] = Vector.tabulate(n)(i => newInlet[T1](s"in${i+1}"))
def in(n: Int): Inlet[T1] = {
require(n > 0, "n must be > 0")
in1Seq(n - 1)
}
}
[2..#class FanInShape1[[#T0#], O](_init: FanInShape.Init[O]) extends FanInShape[O](_init) {
def this(name: String) = this(FanInShape.Name(name))
def this([#in0: Inlet[T0]#], out: Outlet[O]) = this(FanInShape.Ports(out, [#in0# :: ] :: Nil))