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

Flowable.concatMapCompletableDelayError介绍

[英]Maps the upstream items into CompletableSources and subscribes to them one after the other terminates, delaying all errors till both this Flowable and all inner CompletableSources terminate.

Backpressure: The operator expects the upstream to support backpressure. If this Flowable violates the rule, the operator will signal a MissingBackpressureException. Scheduler: concatMapCompletableDelayError does not operate by default on a particular Scheduler.
[中]将上游项映射到CompletableSources中，并在另一个终止后一个接一个地订阅它们，延迟所有错误，直到此可流动源和所有内部CompletableSources终止。
背压：操作员希望上游支持背压。如果该流体违反规则，操作员将发出缺少背压异常的信号。调度程序：默认情况下，concatMapCompletableDelayError不会在特定调度程序上运行。

代码示例

代码示例来源：origin: ReactiveX/RxJava

/**
 * Maps the upstream items into {@link CompletableSource}s and subscribes to them one after the
 * other terminates, delaying all errors till both this {@code Flowable} and all
 * inner {@code CompletableSource}s terminate.
 * <p>
 * <img width="640" height="305" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/concatMap.png" alt="">
 * <dl>
 *  <dt><b>Backpressure:</b></dt>
 *  <dd>The operator expects the upstream to support backpressure. If this {@code Flowable} violates the rule, the operator will
 *  signal a {@code MissingBackpressureException}.</dd>
 *  <dt><b>Scheduler:</b></dt>
 *  <dd>{@code concatMapCompletableDelayError} does not operate by default on a particular {@link Scheduler}.</dd>
 * </dl>
 * <p>History: 2.1.11 - experimental
 * @param mapper the function called with the upstream item and should return
 *               a {@code CompletableSource} to become the next source to
 *               be subscribed to
 * @return a new Completable instance
 * @see #concatMapCompletable(Function, int)
 * @since 2.2
 */
@CheckReturnValue
@SchedulerSupport(SchedulerSupport.NONE)
@BackpressureSupport(BackpressureKind.FULL)
public final Completable concatMapCompletableDelayError(Function<? super T, ? extends CompletableSource> mapper) {
  return concatMapCompletableDelayError(mapper, true, 2);
}

代码示例来源：origin: ReactiveX/RxJava

@BackpressureSupport(BackpressureKind.FULL)
public final Completable concatMapCompletableDelayError(Function<? super T, ? extends CompletableSource> mapper, boolean tillTheEnd) {
  return concatMapCompletableDelayError(mapper, tillTheEnd, 2);

代码示例来源：origin: redisson/redisson

/**
 * Maps the upstream items into {@link CompletableSource}s and subscribes to them one after the
 * other terminates, delaying all errors till both this {@code Flowable} and all
 * inner {@code CompletableSource}s terminate.
 * <p>
 * <img width="640" height="305" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/concatMap.png" alt="">
 * <dl>
 *  <dt><b>Backpressure:</b></dt>
 *  <dd>The operator expects the upstream to support backpressure. If this {@code Flowable} violates the rule, the operator will
 *  signal a {@code MissingBackpressureException}.</dd>
 *  <dt><b>Scheduler:</b></dt>
 *  <dd>{@code concatMapCompletableDelayError} does not operate by default on a particular {@link Scheduler}.</dd>
 * </dl>
 * @param mapper the function called with the upstream item and should return
 *               a {@code CompletableSource} to become the next source to
 *               be subscribed to
 * @return a new Completable instance
 * @since 2.1.11 - experimental
 * @see #concatMapCompletable(Function, int)
 */
@CheckReturnValue
@SchedulerSupport(SchedulerSupport.NONE)
@BackpressureSupport(BackpressureKind.FULL)
@Experimental
public final Completable concatMapCompletableDelayError(Function<? super T, ? extends CompletableSource> mapper) {
  return concatMapCompletableDelayError(mapper, true, 2);
}

代码示例来源：origin: redisson/redisson

@Experimental
public final Completable concatMapCompletableDelayError(Function<? super T, ? extends CompletableSource> mapper, boolean tillTheEnd) {
  return concatMapCompletableDelayError(mapper, tillTheEnd, 2);

代码示例来源：origin: ReactiveX/RxJava

@Test
public void innerErrorDelayed() {
  Flowable.range(1, 5)
  .concatMapCompletableDelayError(
      new Function<Integer, CompletableSource>() {
        @Override
        public CompletableSource apply(Integer v) throws Exception {
          return Completable.error(new TestException());
        }
      }
  )
  .test()
  .assertFailure(CompositeException.class)
  .assertOf(new Consumer<TestObserver<Void>>() {
    @Override
    public void accept(TestObserver<Void> to) throws Exception {
      assertEquals(5, ((CompositeException)to.errors().get(0)).getExceptions().size());
    }
  });
}