@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()); }
public static <T> OnSubscribeFunc<Notification<T>> materialize(final Observable<? extends T> sequence) { return new MaterializeObservable<T>(sequence); }
OperationMaterialize { public static <T> OnSubscribeFunc<Notification<T>> materialize(final Observable<? extends T> sequence) { return new MaterializeObservable<T>(sequence); } }
OperationMaterialize { public static <T> OnSubscribeFunc<Notification<T>> materialize(final Observable<? extends T> sequence) { return new MaterializeObservable<T>(sequence); }  }
OperationMaterialize { public static <T> OnSubscribeFunc<Notification<T>> materialize(final Observable<? extends T> sequence) { return new MaterializeObservable<T>(sequence); }  static OnSubscribeFunc<Notification<T>> materialize(final Observable<? extends T> sequence); }
OperationMaterialize { public static <T> OnSubscribeFunc<Notification<T>> materialize(final Observable<? extends T> sequence) { return new MaterializeObservable<T>(sequence); }  static OnSubscribeFunc<Notification<T>> materialize(final Observable<? extends T> sequence);  }