rx.Observable.subscribeOn()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(6.8k)|赞(0)|评价(0)|浏览(234)

本文整理了Java中rx.Observable.subscribeOn()方法的一些代码示例,展示了Observable.subscribeOn()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Observable.subscribeOn()方法的具体详情如下:
包路径:rx.Observable
类名称:Observable
方法名:subscribeOn

Observable.subscribeOn介绍

[英]Asynchronously subscribes Observers to this Observable on the specified Scheduler.

Scheduler: you specify which Scheduler this operator will use
[中]在指定的调度程序上异步订阅此可观察对象的观察者。
调度器:指定该操作员将使用的调度器

代码示例

代码示例来源:origin: greenrobot/greenDAO

  1. protected <R> Observable<R> wrap(Observable<R> observable) {
  2. if (scheduler != null) {
  3. return observable.subscribeOn(scheduler);
  4. } else {
  5. return observable;
  6. }
  7. }

代码示例来源:origin: PipelineAI/pipeline

  1. @Override
  2. protected Observable<Boolean> construct() {
  3. return Observable.create(new OnSubscribe<Boolean>() {
  4. @Override
  5. public void call(Subscriber<? super Boolean> s) {
  6. results.isContextInitialized.set(HystrixRequestContext.isCurrentThreadInitialized());
  7. results.originThread.set(Thread.currentThread());
  8. s.onError(new RuntimeException("graceful onError"));
  9. }
  10. }).subscribeOn(userScheduler);
  11. }

代码示例来源:origin: PipelineAI/pipeline

  1. @Override
  2. protected Observable<Boolean> construct() {
  3. return Observable.create(new OnSubscribe<Boolean>() {
  4. @Override
  5. public void call(Subscriber<? super Boolean> s) {
  6. s.onError(new RuntimeException("onError"));
  7. }
  8. }).subscribeOn(userScheduler);
  9. }

代码示例来源:origin: PipelineAI/pipeline

  1. @Override
  2. protected Observable<Boolean> construct() {
  3. return Observable.create(new OnSubscribe<Boolean>() {
  4. @Override
  5. public void call(Subscriber<? super Boolean> s) {
  6. s.onError(new RuntimeException("onError"));
  7. }
  8. }).subscribeOn(userScheduler);
  9. }

代码示例来源:origin: PipelineAI/pipeline

  1. @Override
  2. protected Observable<Boolean> construct() {
  3. return Observable.create(new OnSubscribe<Boolean>() {
  4. @Override
  5. public void call(Subscriber<? super Boolean> s) {
  6. results.isContextInitialized.set(HystrixRequestContext.isCurrentThreadInitialized());
  7. results.originThread.set(Thread.currentThread());
  8. throw new RuntimeException("bad onError");
  9. }
  10. }).subscribeOn(userScheduler);
  11. }

代码示例来源:origin: PipelineAI/pipeline

  1. @Override
  2. protected Observable<Boolean> resumeWithFallback() {
  3. return Observable.create(new OnSubscribe<Boolean>() {
  4. @Override
  5. public void call(Subscriber<? super Boolean> s) {
  6. results.isContextInitialized.set(HystrixRequestContext.isCurrentThreadInitialized());
  7. results.originThread.set(Thread.currentThread());
  8. s.onNext(false);
  9. s.onCompleted();
  10. }
  11. }).subscribeOn(userScheduler);
  12. }

代码示例来源:origin: PipelineAI/pipeline

  1. @Override
  2. protected Observable<Boolean> resumeWithFallback() {
  3. return Observable.create(new OnSubscribe<Boolean>() {
  4. @Override
  5. public void call(Subscriber<? super Boolean> s) {
  6. results.isContextInitialized.set(HystrixRequestContext.isCurrentThreadInitialized());
  7. results.originThread.set(Thread.currentThread());
  8. s.onNext(false);
  9. s.onCompleted();
  10. }
  11. }).subscribeOn(userScheduler);
  12. }

代码示例来源:origin: PipelineAI/pipeline

  1. @Override
  2. protected Observable<Boolean> construct() {
  3. return Observable.create(new OnSubscribe<Boolean>() {
  4. @Override
  5. public void call(Subscriber<? super Boolean> s) {
  6. results.isContextInitialized.set(HystrixRequestContext.isCurrentThreadInitialized());
  7. results.originThread.set(Thread.currentThread());
  8. s.onNext(true);
  9. s.onCompleted();
  10. }
  11. }).subscribeOn(userScheduler);
  12. }

代码示例来源:origin: PipelineAI/pipeline

  1. @Override
  2. protected Observable<Boolean> resumeWithFallback() {
  3. return Observable.create(new OnSubscribe<Boolean>() {
  4. @Override
  5. public void call(Subscriber<? super Boolean> s) {
  6. results.isContextInitialized.set(HystrixRequestContext.isCurrentThreadInitialized());
  7. results.originThread.set(Thread.currentThread());
  8. s.onNext(false);
  9. s.onCompleted();
  10. }
  11. }).subscribeOn(userScheduler);
  12. }

代码示例来源:origin: PipelineAI/pipeline

  1. @Override
  2. protected Observable<Boolean> resumeWithFallback() {
  3. return Observable.create(new OnSubscribe<Boolean>() {
  4. @Override
  5. public void call(Subscriber<? super Boolean> s) {
  6. results.isContextInitialized.set(HystrixRequestContext.isCurrentThreadInitialized());
  7. results.originThread.set(Thread.currentThread());
  8. s.onNext(false);
  9. s.onCompleted();
  10. }
  11. }).subscribeOn(userScheduler);
  12. }

代码示例来源:origin: PipelineAI/pipeline

  1. @Override
  2. protected Observable<Boolean> construct() {
  3. System.out.println("successfully executed");
  4. return Observable.just(true).subscribeOn(Schedulers.computation());
  5. }

代码示例来源:origin: PipelineAI/pipeline

  1. @Override
  2. protected Observable<Boolean> resumeWithFallback() {
  3. return Observable.just(false).subscribeOn(Schedulers.computation());
  4. }
  5. }

代码示例来源:origin: PipelineAI/pipeline

  1. @Override
  2. protected Observable<T> construct() {
  3. executed = true;
  4. System.out.println("successfully executed");
  5. return Observable.just(value).subscribeOn(Schedulers.computation());
  6. }

代码示例来源:origin: PipelineAI/pipeline

  1. @Override
  2. protected Observable<Boolean> construct() {
  3. System.out.println("successfully executed");
  4. return Observable.just(true).subscribeOn(Schedulers.computation());
  5. }

代码示例来源:origin: PipelineAI/pipeline

  1. @Override
  2. protected Observable<String> construct() {
  3. executed = true;
  4. System.out.println("successfully executed");
  5. return Observable.just(value).subscribeOn(Schedulers.computation());
  6. }

代码示例来源:origin: PipelineAI/pipeline

  1. @Override
  2. protected Observable<Boolean> construct() {
  3. System.out.println("successfully executed");
  4. return Observable.just(true).subscribeOn(Schedulers.computation());
  5. }

代码示例来源:origin: square/retrofit

  1. @Override public Object adapt(Call<R> call) {
  2. OnSubscribe<Response<R>> callFunc = isAsync
  3. ? new CallEnqueueOnSubscribe<>(call)
  4. : new CallExecuteOnSubscribe<>(call);
  5. OnSubscribe<?> func;
  6. if (isResult) {
  7. func = new ResultOnSubscribe<>(callFunc);
  8. } else if (isBody) {
  9. func = new BodyOnSubscribe<>(callFunc);
  10. } else {
  11. func = callFunc;
  12. }
  13. Observable<?> observable = Observable.create(func);
  14. if (scheduler != null) {
  15. observable = observable.subscribeOn(scheduler);
  16. }
  17. if (isSingle) {
  18. return observable.toSingle();
  19. }
  20. if (isCompletable) {
  21. return observable.toCompletable();
  22. }
  23. return observable;
  24. }
  25. }

代码示例来源:origin: PipelineAI/pipeline

  1. @Override
  2. protected Observable<Integer> construct() {
  3. return Observable.just(1, 2, 3)
  4. .concatWith(Observable.<Integer> error(new RuntimeException("forced error")))
  5. .subscribeOn(Schedulers.computation());
  6. }

代码示例来源:origin: PipelineAI/pipeline

  1. @Override
  2. protected Observable<Boolean> construct() {
  3. return Observable.just(false, true, false)
  4. .concatWith(Observable.<Boolean>error(new RuntimeException("forced error")))
  5. .subscribeOn(Schedulers.computation());
  6. }

代码示例来源:origin: PipelineAI/pipeline

  1. @Override
  2. protected Observable<String> construct() {
  3. executed = true;
  4. return Observable.just(value).delay(duration, TimeUnit.MILLISECONDS).subscribeOn(Schedulers.computation())
  5. .doOnNext(new Action1<String>() {
  6. @Override
  7. public void call(String t1) {
  8. System.out.println("successfully executed");
  9. }
  10. });
  11. }

相关文章

Observable类方法