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

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

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

Observable.concatWith介绍

[英]Returns an Observable that emits the items emitted from the current Observable, then the next, one after the other, without interleaving them.

Scheduler: concat does not operate by default on a particular Scheduler.
[中]返回一个Observable，该Observable发出从当前Observable发出的项，然后是下一个Observable，一个接一个，而不交错它们。
调度器：默认情况下，concat不会在特定的调度器上运行。

代码示例

代码示例来源：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: com.microsoft.azure/azure-mgmt-resources

  1. @Override
  2.   public Observable<ServiceResponse<Page<SubscriptionInner>>> call(ServiceResponse<Page<SubscriptionInner>> page) {
  3.     String nextPageLink = page.body().nextPageLink();
  4.     if (nextPageLink == null) {
  5.       return Observable.just(page);
  6.     }
  7.     return Observable.just(page).concatWith(listNextWithServiceResponseAsync(nextPageLink));
  8.   }
  9. });

代码示例来源：origin: com.microsoft.azure/azure-mgmt-resources

  1. @Override
  2.   public Observable<ServiceResponse<Page<PolicySetDefinitionInner>>> call(ServiceResponse<Page<PolicySetDefinitionInner>> page) {
  3.     String nextPageLink = page.body().nextPageLink();
  4.     if (nextPageLink == null) {
  5.       return Observable.just(page);
  6.     }
  7.     return Observable.just(page).concatWith(listNextWithServiceResponseAsync(nextPageLink));
  8.   }
  9. });

代码示例来源：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: com.microsoft.azure/azure-mgmt-resources

  1. @Override
  2.   public Observable<ServiceResponse<Page<PolicySetDefinitionInner>>> call(ServiceResponse<Page<PolicySetDefinitionInner>> page) {
  3.     String nextPageLink = page.body().nextPageLink();
  4.     if (nextPageLink == null) {
  5.       return Observable.just(page);
  6.     }
  7.     return Observable.just(page).concatWith(listBuiltInNextWithServiceResponseAsync(nextPageLink));
  8.   }
  9. });

代码示例来源：origin: davidmoten/rxjava-jdbc

  1. /**
  2.  * Sets a named parameter. If name is null throws a
  3.  * {@link NullPointerException}. If value is instance of Observable then
  4.  * throws an {@link IllegalArgumentException}.
  5.  * 
  6.  * @param name
  7.  *            the parameter name. Cannot be null.
  8.  * @param value
  9.  *            the parameter value
  10.  */
  11. void parameter(String name, Object value) {
  12.   Preconditions.checkNotNull(name, "parameter name cannot be null");
  13.   if (value instanceof Observable)
  14.     throw new IllegalArgumentException(
  15.         "use parameters() method not the parameter() method for an Observable");
  16.   this.parameters = parameters.concatWith(Observable.just(new Parameter(name, value)));
  17. }

代码示例来源：origin: com.microsoft.azure/azure-mgmt-resources

  1. @Override
  2.   public Observable<ServiceResponse<Page<ProviderInner>>> call(ServiceResponse<Page<ProviderInner>> page) {
  3.     String nextPageLink = page.body().nextPageLink();
  4.     if (nextPageLink == null) {
  5.       return Observable.just(page);
  6.     }
  7.     return Observable.just(page).concatWith(listNextWithServiceResponseAsync(nextPageLink));
  8.   }
  9. });

代码示例来源：origin: jhusain/learnrxjava

  1. Observable.just("Hello", "World!")
  2.     .subscribe(System.out::println);
  3.         System.out.println("delay retry by " + i + " second(s)");
  4.         return Observable.timer(i, TimeUnit.SECONDS);
  5.       }).concatWith(Observable.error(new RuntimeException("Exceeded 3 retries")));
  6. })
  7.     .subscribe(System.out::println, t -> t.printStackTrace());

代码示例来源：origin: com.microsoft.azure/azure-mgmt-resources

  1. @Override
  2.   public Observable<ServiceResponse<Page<PolicyDefinitionInner>>> call(ServiceResponse<Page<PolicyDefinitionInner>> page) {
  3.     String nextPageLink = page.body().nextPageLink();
  4.     if (nextPageLink == null) {
  5.       return Observable.just(page);
  6.     }
  7.     return Observable.just(page).concatWith(listByManagementGroupNextWithServiceResponseAsync(nextPageLink));
  8.   }
  9. });

代码示例来源：origin: com.microsoft.azure/azure-mgmt-resources

  1. @Override
  2.   public Observable<ServiceResponse<Page<FeatureResultInner>>> call(ServiceResponse<Page<FeatureResultInner>> page) {
  3.     String nextPageLink = page.body().nextPageLink();
  4.     if (nextPageLink == null) {
  5.       return Observable.just(page);
  6.     }
  7.     return Observable.just(page).concatWith(list1NextWithServiceResponseAsync(nextPageLink));
  8.   }
  9. });

代码示例来源：origin: com.microsoft.azure/azure-mgmt-resources

  1. @Override
  2.   public Observable<ServiceResponse<Page<TagDetailsInner>>> call(ServiceResponse<Page<TagDetailsInner>> page) {
  3.     String nextPageLink = page.body().nextPageLink();
  4.     if (nextPageLink == null) {
  5.       return Observable.just(page);
  6.     }
  7.     return Observable.just(page).concatWith(listNextWithServiceResponseAsync(nextPageLink));
  8.   }
  9. });

代码示例来源：origin: com.microsoft.azure/azure-mgmt-resources

  1. @Override
  2.   public Observable<ServiceResponse<Page<PolicyAssignmentInner>>> call(ServiceResponse<Page<PolicyAssignmentInner>> page) {
  3.     String nextPageLink = page.body().nextPageLink();
  4.     if (nextPageLink == null) {
  5.       return Observable.just(page);
  6.     }
  7.     return Observable.just(page).concatWith(listForResourceNextWithServiceResponseAsync(nextPageLink));
  8.   }
  9. });

代码示例来源：origin: com.microsoft.azure/azure-mgmt-resources

  1. @Override
  2.   public Observable<ServiceResponse<Page<PolicyAssignmentInner>>> call(ServiceResponse<Page<PolicyAssignmentInner>> page) {
  3.     String nextPageLink = page.body().nextPageLink();
  4.     if (nextPageLink == null) {
  5.       return Observable.just(page);
  6.     }
  7.     return Observable.just(page).concatWith(listByResourceGroupNextWithServiceResponseAsync(nextPageLink));
  8.   }
  9. });

代码示例来源：origin: com.microsoft.azure/azure-mgmt-resources

  1. @Override
  2.   public Observable<ServiceResponse<Page<SubscriptionInner>>> call(ServiceResponse<Page<SubscriptionInner>> page) {
  3.     String nextPageLink = page.body().nextPageLink();
  4.     if (nextPageLink == null) {
  5.       return Observable.just(page);
  6.     }
  7.     return Observable.just(page).concatWith(listNextWithServiceResponseAsync(nextPageLink));
  8.   }
  9. });

代码示例来源：origin: com.microsoft.azure/azure-mgmt-resources

  1. @Override
  2.   public Observable<ServiceResponse<Page<PolicySetDefinitionInner>>> call(ServiceResponse<Page<PolicySetDefinitionInner>> page) {
  3.     String nextPageLink = page.body().nextPageLink();
  4.     if (nextPageLink == null) {
  5.       return Observable.just(page);
  6.     }
  7.     return Observable.just(page).concatWith(listByManagementGroupNextWithServiceResponseAsync(nextPageLink));
  8.   }
  9. });

代码示例来源：origin: com.microsoft.azure/azure-mgmt-resources

  1. @Override
  2.   public Observable<ServiceResponse<Page<PolicySetDefinitionInner>>> call(ServiceResponse<Page<PolicySetDefinitionInner>> page) {
  3.     String nextPageLink = page.body().nextPageLink();
  4.     if (nextPageLink == null) {
  5.       return Observable.just(page);
  6.     }
  7.     return Observable.just(page).concatWith(listByManagementGroupNextWithServiceResponseAsync(nextPageLink));
  8.   }
  9. });

代码示例来源：origin: com.microsoft.azure/azure-mgmt-resources

  1. @Override
  2.   public Observable<ServiceResponse<Page<ResourceGroupInner>>> call(ServiceResponse<Page<ResourceGroupInner>> page) {
  3.     String nextPageLink = page.body().nextPageLink();
  4.     if (nextPageLink == null) {
  5.       return Observable.just(page);
  6.     }
  7.     return Observable.just(page).concatWith(listNextWithServiceResponseAsync(nextPageLink));
  8.   }
  9. });

代码示例来源：origin: com.microsoft.azure/azure-mgmt-resources

  1. @Override
  2.   public Observable<ServiceResponse<Page<PolicyDefinitionInner>>> call(ServiceResponse<Page<PolicyDefinitionInner>> page) {
  3.     String nextPageLink = page.body().nextPageLink();
  4.     if (nextPageLink == null) {
  5.       return Observable.just(page);
  6.     }
  7.     return Observable.just(page).concatWith(listBuiltInNextWithServiceResponseAsync(nextPageLink));
  8.   }
  9. });

代码示例来源：origin: com.microsoft.azure/azure-mgmt-resources

  1. @Override
  2.   public Observable<ServiceResponse<Page<PolicyDefinitionInner>>> call(ServiceResponse<Page<PolicyDefinitionInner>> page) {
  3.     String nextPageLink = page.body().nextPageLink();
  4.     if (nextPageLink == null) {
  5.       return Observable.just(page);
  6.     }
  7.     return Observable.just(page).concatWith(listByManagementGroupNextWithServiceResponseAsync(nextPageLink));
  8.   }
  9. });

代码示例来源：origin: com.microsoft.azure/azure-mgmt-resources

  1. @Override
  2.   public Observable<ServiceResponse<Page<TenantIdDescriptionInner>>> call(ServiceResponse<Page<TenantIdDescriptionInner>> page) {
  3.     String nextPageLink = page.body().nextPageLink();
  4.     if (nextPageLink == null) {
  5.       return Observable.just(page);
  6.     }
  7.     return Observable.just(page).concatWith(listNextWithServiceResponseAsync(nextPageLink));
  8.   }
  9. });

内容来源于网络，如有侵权，请联系作者删除！

Observable

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    Observable类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com