@Test
public void testMultipleSubscribes() throws InterruptedException, ExecutionException {

    final TestAsyncErrorObservable o = new TestAsyncErrorObservable("one", "two", null, "three");
    Observable<Notification<String>> m = Observable.create(materialize(Observable.create(o)));
    assertEquals(3, m.toList().toBlockingObservable().toFuture().get().size());
    assertEquals(3, m.toList().toBlockingObservable().toFuture().get().size());
}