=str #15869 Re-enable flow graph checks

This commit is contained in:
Patrik Nordwall 2014-09-12 12:12:32 +02:00
parent 55f5dac241
commit 419daa7a86
2 changed files with 48 additions and 25 deletions

View file

@ -251,5 +251,27 @@ class FlowGraphCompileSpec extends AkkaSpec {
}.getMessage should include("empty")
}
"check maximumInputCount" in {
intercept[IllegalArgumentException] {
FlowGraph { implicit b
val bcast = Broadcast[String]
import FlowGraphImplicits._
in1 ~> bcast ~> out1
in2 ~> bcast // wrong
}
}.getMessage should include("at most 1 incoming")
}
"check maximumOutputCount" in {
intercept[IllegalArgumentException] {
FlowGraph { implicit b
val merge = Merge[String]
import FlowGraphImplicits._
in1 ~> merge ~> out1
merge ~> out2 // wrong
}
}.getMessage should include("at most 1 outgoing")
}
}
}