@Test public void confluent() { CoreOperatorFactory f = new CoreOperatorFactory(); out.add(f.confluent(in, in2)); Graph<String> graph = toGraph(); assertThat( graph.getConnected("in"), connected(CONFLUENT_NAME)); assertThat( graph.getConnected("in2"), connected(CONFLUENT_NAME)); assertThat( graph.getConnected(CONFLUENT_NAME), connected("out")); }
public <T> Confluent<T> confluent(Source<T> a, Source<T> b) { if (a == null) { throw new IllegalArgumentException("a must not be null"); } if (b == null) { throw new IllegalArgumentException("b must not be null"); } Type type = getPortType(a); List<Source<T>> input = new ArrayList<>(); input.add(a); input.add(b); return new Confluent<>(type, input); }
CoreOperatorFactory { public <T> Confluent<T> confluent(Source<T> a, Source<T> b) { if (a == null) { throw new IllegalArgumentException("a must not be null"); } if (b == null) { throw new IllegalArgumentException("b must not be null"); } Type type = getPortType(a); List<Source<T>> input = new ArrayList<>(); input.add(a); input.add(b); return new Confluent<>(type, input); } }
CoreOperatorFactory { public <T> Confluent<T> confluent(Source<T> a, Source<T> b) { if (a == null) { throw new IllegalArgumentException("a must not be null"); } if (b == null) { throw new IllegalArgumentException("b must not be null"); } Type type = getPortType(a); List<Source<T>> input = new ArrayList<>(); input.add(a); input.add(b); return new Confluent<>(type, input); }  }
CoreOperatorFactory { public <T> Confluent<T> confluent(Source<T> a, Source<T> b) { if (a == null) { throw new IllegalArgumentException("a must not be null"); } if (b == null) { throw new IllegalArgumentException("b must not be null"); } Type type = getPortType(a); List<Source<T>> input = new ArrayList<>(); input.add(a); input.add(b); return new Confluent<>(type, input); }  Empty<T> empty(Class<T> type); Empty<T> empty(Type type); EmptyFragment empty(); void stop(Source<?> in); Confluent<T> confluent(Source<T> a, Source<T> b); Confluent<T> confluent(Source<T> a, Source<T> b, Source<T> c); Confluent<T> confluent(Source<T> a, Source<T> b, Source<T> c, Source<T> d); Confluent<T> confluent(Iterable<? extends Source<T>> inputs); @SafeVarargs final Confluent<T> confluent(Source<T>... inputs); Checkpoint<T> checkpoint(Source<T> in); Project<T> project(Source<?> in, Class<T> targetType); ProjectFragment project(Source<?> in); Extend<T> extend(Source<?> in, Class<T> targetType); ExtendFragment extend(Source<?> in); Restructure<T> restructure(Source<?> in, Class<T> targetType); RestructureFragment restructure(Source<?> in); }
CoreOperatorFactory { public <T> Confluent<T> confluent(Source<T> a, Source<T> b) { if (a == null) { throw new IllegalArgumentException("a must not be null"); } if (b == null) { throw new IllegalArgumentException("b must not be null"); } Type type = getPortType(a); List<Source<T>> input = new ArrayList<>(); input.add(a); input.add(b); return new Confluent<>(type, input); }  Empty<T> empty(Class<T> type); Empty<T> empty(Type type); EmptyFragment empty(); void stop(Source<?> in); Confluent<T> confluent(Source<T> a, Source<T> b); Confluent<T> confluent(Source<T> a, Source<T> b, Source<T> c); Confluent<T> confluent(Source<T> a, Source<T> b, Source<T> c, Source<T> d); Confluent<T> confluent(Iterable<? extends Source<T>> inputs); @SafeVarargs final Confluent<T> confluent(Source<T>... inputs); Checkpoint<T> checkpoint(Source<T> in); Project<T> project(Source<?> in, Class<T> targetType); ProjectFragment project(Source<?> in); Extend<T> extend(Source<?> in, Class<T> targetType); ExtendFragment extend(Source<?> in); Restructure<T> restructure(Source<?> in, Class<T> targetType); RestructureFragment restructure(Source<?> in); static final String EMPTY_NAME; static final String STOP_NAME; static final String CONFLUENT_NAME; static final String CHECKPOINT_NAME; static final String PROJECT_NAME; static final String EXTEND_NAME; static final String RESTRUCTURE_NAME; }