io.reactivex.schedulers.Schedulers#trampoline ( )源码实例Demo

@Before
public void setUp() {
    Context systemContext = RuntimeEnvironment.systemContext;

    TestAppComponent component = DaggerTestAppComponent
            .builder()
            .context(systemContext)
            .build();

    component.inject(this);

    view = mock(SettingsView.class);
    disposable = new CompositeDisposable();

    presenter = new SettingsPresenter(
            router,
            accountInteractor,
            logoutInteractor,
            api,
            securityInteractor,
            switchPushNotificationServiceInteractor,
            Schedulers.trampoline()
    );
}
 

/**
 * 用于处理订阅事件在那个线程中执行
 *
 * @param observable       d
 * @param subscriberMethod d
 * @return Observable
 */
private Flowable postToObservable(Flowable observable, SubscriberMethod subscriberMethod) {
    Scheduler scheduler;
    switch (subscriberMethod.threadMode) {
        case MAIN:
            scheduler = AndroidSchedulers.mainThread();
            break;

        case NEW_THREAD:
            scheduler = Schedulers.newThread();
            break;

        case CURRENT_THREAD:
            scheduler = Schedulers.trampoline();
            break;
        default:
            throw new IllegalStateException("Unknown thread mode: " + subscriberMethod.threadMode);
    }
    return observable.observeOn(scheduler);
}
 

@Before
public void setUp() {
    MockitoAnnotations.initMocks(this);

    presenter = new TimelinePresenter(twitterService, Schedulers.trampoline());

    user = new User("Bob", "bob", "");
    timelineItems = new ArrayList<>();
    timelineItems.add(new TimelineItem("", "", user));

    when(twitterService.getTimelineItems()).thenReturn(Observable.just(timelineItems));
    when(twitterService.getMyDetails()).thenReturn(Observable.just(user));
}
 

private void demo0() {
    Schedulers.single();
    Schedulers.trampoline();
    Schedulers.newThread();
    Schedulers.computation();
    Schedulers.io();
    Schedulers.io();
}
 

private void demo0() {
    Schedulers.single();
    Schedulers.trampoline();
    Schedulers.newThread();
    Schedulers.computation();
    Schedulers.io();
    Schedulers.io();
}
 

@NonNull
@Override
public Scheduler computation() {
  return Schedulers.trampoline();
}
 

@NonNull
@Override
public Scheduler io() {
  return Schedulers.trampoline();
}
 

@NonNull
@Override
public Scheduler ui() {
  return Schedulers.trampoline();
}
 

@Named(Constants.UI_SCHEDULER)
@Singleton
@Provides
public static Scheduler provideUIObserveScheduler() {
    return Schedulers.trampoline();
}
 

@NonNull
@Override
public Scheduler computation() {
  return Schedulers.trampoline();
}
 

public static Rx test() {
  return new Rx(Schedulers.trampoline(), Schedulers.trampoline(), Schedulers.trampoline());
}
 

@NonNull
@Override
public Scheduler ui() {
  return Schedulers.trampoline();
}
 

@NonNull
@Override
public Scheduler multi() {
  return Schedulers.trampoline();
}
 

@NonNull
@Override
public Scheduler computation() {
    return Schedulers.trampoline();
}
 

@Override
@NonNull
protected Scheduler defaultRxScheduler() {
    return Schedulers.trampoline();
}
 

@NonNull
@Override
public Scheduler ui() {
    return Schedulers.trampoline();
}
 

public Scheduler getScheduler() {
    return Schedulers.trampoline();
}
 

@Override
public Scheduler mainThread() {
    return Schedulers.trampoline();
}
 

@Override
public Scheduler backgroundThread() {
    return Schedulers.trampoline();
}
 

/**
 * Provides the trampoline thread Scheduler.
 *
 * @return provides the trampoline thread Scheduler.
 */
@Override
public Scheduler provideTrampolineScheduler() {
    return Schedulers.trampoline();
}