@Test
public void eventsAreForwardedInOrder() throws Exception {

  EventSource<Integer> source = RxEventSources.fromObservables(Observable.just(1, 2, 3));
  RecordingConsumer<Integer> consumer = new RecordingConsumer<>();
  source.subscribe(consumer);
  consumer.waitForChange(50);
  consumer.assertValues(1, 2, 3);
}