@Test
public void testCreate() {

    Counter counter = new Counter();
    ListDataStream<Integer> integers = ListDataStream.create(1, 2, 3);
    integers.subscribe(counter);
    assertEquals(3, counter.count);
}