ListDataStream implements DataStream<T> { @SafeVarargs public static <T> ListDataStream<T> create(T... ts) { ListDataStream<T> stream = new ListDataStream<>(); for (T t : ts) { stream.append(t); } return stream; }  @SafeVarargs static ListDataStream<T> create(T... ts); @Override void append(T t); @Override void subscribe(DataProcessor subscriber);  }
@Test public void testCreate() { Counter counter = new Counter(); ListDataStream<Integer> integers = ListDataStream.create(1, 2, 3); integers.subscribe(counter); assertEquals(3, counter.count); }