io.reactivex.Single#subscribeOn ( )源码实例Demo

public static <T> T testSingle(Single<T> single) {
    assertNotNull("Single itself was null", single);
    // If you don't do this it blocks trying to do the operation and therefore can't observe the results
    single = single.subscribeOn(Schedulers.io());
    TestObserver<T> observer = single.test();
    assertTrue("Observer failed to reach terminal event", observer.awaitTerminalEvent());
    observer.assertNoErrors();
    T object = observer.values().get(0);
    assertNotNull("Returned object was null - RxJava should not allow this", object);
    return object;
}
 

@CheckResult
@NonNull
public static <T> Single<T> subscribeOn(
        @NonNull StorIOSQLite storIOSQLite,
        @NonNull Single<T> single
) {
    final Scheduler scheduler = storIOSQLite.defaultRxScheduler();
    return scheduler != null ? single.subscribeOn(scheduler) : single;
}
 

@CheckResult
@NonNull
public static <T> Single<T> subscribeOn(
        @NonNull StorIOContentResolver storIOContentResolver,
        @NonNull Single<T> single
) {
    final Scheduler scheduler = storIOContentResolver.defaultRxScheduler();
    return scheduler != null ? single.subscribeOn(scheduler) : single;
}
 

private <T> Single<T> assign(Single<T> single) {
    return single.subscribeOn(BurstKitUtils.defaultBurstNodeServiceScheduler());
}