Balance should also be allowed to have just one input
This commit is contained in:
parent
26e2dcb857
commit
6ad1eab8e6
3 changed files with 17 additions and 4 deletions
|
|
@ -59,7 +59,7 @@ class GraphMergeSpec extends TwoStreamsSetup {
|
|||
probe.expectComplete()
|
||||
}
|
||||
|
||||
"work with 1-way merge" in {
|
||||
"work with one-way merge" in {
|
||||
val result = Source.fromGraph(GraphDSL.create() { implicit b ⇒
|
||||
val merge = b.add(Merge[Int](1))
|
||||
val source = b.add(Source(1 to 3))
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue