content

final Flow<String, String> f1 = Flow.of(String.class).transform("f1", this.<String, String>op()); // javadsl
    final Flow<String, String> f2 = Flow.of(String.class).transform("f2", this.<String, String>op()); // javadsl
    final Flow<String, String> f3 = Flow.of(String.class).transform("f2", this.<String, String>op()); // javadsl

    // TODO what do we want to do here, so scaladsl does not leak into javadls usage via using Taps?
    final IterableTap<String> in1 = new IterableTap<String>(Util.immutableSeq(Arrays.asList("a", "b", "c"))); // scaladsl
    final IterableTap<String> in2 = new IterableTap<String>(Util.immutableSeq(Arrays.asList("d", "e", "f"))); // scaladsl
    final PublisherDrain<String> out1 = new PublisherDrain<String>();
    final FutureDrain<String> out2 = new FutureDrain<String>();

    // TODO FLOW GRAPH
    JavaFlowGraph.construct(new BobTheBuilder() {
      @Override
      public JavaFlowGraph connect(JavaFlowGraphBuilder b) {
        Merge<String> merge = Merge.apply();

        return b.
          addEdge(in1, f1, merge). // would rather use in1/in3 as javadsl
          addEdge(in2, f2, merge).
          addEdge(merge, f3, out1);
      }
    }).run(materializer);