=str Source/Sink vs SourceVertex/SinkVertex equality

* it must be possible to use PublisherSink (object) at several places in the graph
This commit is contained in:
Patrik Nordwall 2014-09-10 13:40:14 +02:00
parent 5999d8dfc2
commit 5b360a76b0
3 changed files with 8 additions and 6 deletions

View file

@ -144,9 +144,8 @@ class FlowGraphCompileSpec extends AkkaSpec {
val in5 = IterableSource(List("b"))
val in7 = IterableSource(List("a"))
val out2 = PublisherSink[String]
val out9 = FutureSink[String]
val out10 = ForeachSink[String](_ ())
// FIXME PublisherSink can't be object, equality
val out9 = PublisherSink[String]
val out10 = PublisherSink[String]
def f(s: String) = FlowFrom[String].transform(s, op[String, String])
import FlowGraphImplicits._