@Test public void startedSubscribes() { TestSubject<String> subject = TestSubject.create(scheduler); RxLoader<String> loader = new RxLoader<>(subject); loader.start(); assertTrue(subject.hasObservers()); }
public static <T> RetainState.OnCreate<RxLoader<T>> create(final Observable<T> observable) { return new RetainState.OnCreate<RxLoader<T>>() { @Override public RxLoader<T> onCreate() { return new RxLoader<>(observable); } }; }
RxLoader extends Loader<Result<T>> { public static <T> RetainState.OnCreate<RxLoader<T>> create(final Observable<T> observable) { return new RetainState.OnCreate<RxLoader<T>>() { @Override public RxLoader<T> onCreate() { return new RxLoader<>(observable); } }; } }
RxLoader extends Loader<Result<T>> { public static <T> RetainState.OnCreate<RxLoader<T>> create(final Observable<T> observable) { return new RetainState.OnCreate<RxLoader<T>>() { @Override public RxLoader<T> onCreate() { return new RxLoader<>(observable); } }; } RxLoader(rx.Observable<T> observable); }
RxLoader extends Loader<Result<T>> { public static <T> RetainState.OnCreate<RxLoader<T>> create(final Observable<T> observable) { return new RetainState.OnCreate<RxLoader<T>>() { @Override public RxLoader<T> onCreate() { return new RxLoader<>(observable); } }; } RxLoader(rx.Observable<T> observable); static RetainState.OnCreate<RxLoader<T>> create(final Observable<T> observable); }
RxLoader extends Loader<Result<T>> { public static <T> RetainState.OnCreate<RxLoader<T>> create(final Observable<T> observable) { return new RetainState.OnCreate<RxLoader<T>>() { @Override public RxLoader<T> onCreate() { return new RxLoader<>(observable); } }; } RxLoader(rx.Observable<T> observable); static RetainState.OnCreate<RxLoader<T>> create(final Observable<T> observable);  }