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

Single.mergeDelayError介绍

[英]Flattens two Singles into a single Flowable, without any transformation, delaying any error(s) until all sources succeed or fail.

You can combine items emitted by multiple Singles so that they appear as a single Flowable, by using the mergeDelayError method. Backpressure: The returned Flowable honors the backpressure of the downstream consumer. Scheduler: mergeDelayError does not operate by default on a particular Scheduler.
[中]将两个单体平坦化为一个可流动的单体，无需任何转换，延迟任何错误，直到所有源成功或失败。
通过使用mergeDelayError方法，可以将多个单体发出的项组合起来，使它们显示为单个可流动项。背压：返回的可流动性尊重下游消费者的背压。调度程序：默认情况下，mergeDelayError不会在特定调度程序上运行。

代码示例

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

/**
 * Merges an Iterable sequence of SingleSource instances into a single Flowable sequence,
 * running all SingleSources at once and delaying any error(s) until all sources succeed or fail.
 * <dl>
 *  <dt><b>Backpressure:</b></dt>
 *  <dd>The returned {@code Flowable} honors the backpressure of the downstream consumer.</dd>
 * <dt><b>Scheduler:</b></dt>
 * <dd>{@code mergeDelayError} does not operate by default on a particular {@link Scheduler}.</dd>
 * </dl>
 * <p>History: 2.1.9 - experimental
 * @param <T> the common and resulting value type
 * @param sources the Iterable sequence of SingleSource sources
 * @return the new Flowable instance
 * @see #merge(Iterable)
 * @since 2.2
 */
@CheckReturnValue
@NonNull
@BackpressureSupport(BackpressureKind.FULL)
@SchedulerSupport(SchedulerSupport.NONE)
public static <T> Flowable<T> mergeDelayError(Iterable<? extends SingleSource<? extends T>> sources) {
  return mergeDelayError(Flowable.fromIterable(sources));
}

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

/**
 * Merges an Iterable sequence of SingleSource instances into a single Flowable sequence,
 * running all SingleSources at once and delaying any error(s) until all sources succeed or fail.
 * <dl>
 *  <dt><b>Backpressure:</b></dt>
 *  <dd>The returned {@code Flowable} honors the backpressure of the downstream consumer.</dd>
 * <dt><b>Scheduler:</b></dt>
 * <dd>{@code mergeDelayError} does not operate by default on a particular {@link Scheduler}.</dd>
 * </dl>
 * @param <T> the common and resulting value type
 * @param sources the Iterable sequence of SingleSource sources
 * @return the new Flowable instance
 * @since 2.1.9 - experimental
 * @see #merge(Iterable)
 */
@CheckReturnValue
@BackpressureSupport(BackpressureKind.FULL)
@SchedulerSupport(SchedulerSupport.NONE)
@Experimental
public static <T> Flowable<T> mergeDelayError(Iterable<? extends SingleSource<? extends T>> sources) {
  return mergeDelayError(Flowable.fromIterable(sources));
}

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

@SuppressWarnings("unchecked")
@Test
public void mergeDelayErrorIterable() {
  Single.mergeDelayError(Arrays.asList(
      Single.just(1),
      Single.<Integer>error(new TestException()),
      Single.just(2))
  )
  .test()
  .assertFailure(TestException.class, 1, 2);
}

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

ObjectHelper.requireNonNull(source1, "source1 is null");
ObjectHelper.requireNonNull(source2, "source2 is null");
return mergeDelayError(Flowable.fromArray(source1, source2));

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

@Test
public void mergeDelayError2() {
  Single.mergeDelayError(
      Single.just(1),
      Single.<Integer>error(new TestException())
  )
  .test()
  .assertFailure(TestException.class, 1);
}

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

@Test
public void mergeDelayError2ErrorFirst() {
  Single.mergeDelayError(
      Single.<Integer>error(new TestException()),
      Single.just(1)
  )
  .test()
  .assertFailure(TestException.class, 1);
}

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

ObjectHelper.requireNonNull(source2, "source2 is null");
ObjectHelper.requireNonNull(source3, "source3 is null");
return mergeDelayError(Flowable.fromArray(source1, source2, source3));

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

@Test
public void mergeDelayError3() {
  Single.mergeDelayError(
      Single.just(1),
      Single.<Integer>error(new TestException()),
      Single.just(2)
  )
  .test()
  .assertFailure(TestException.class, 1, 2);
}

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

ObjectHelper.requireNonNull(source1, "source1 is null");
ObjectHelper.requireNonNull(source2, "source2 is null");
return mergeDelayError(Flowable.fromArray(source1, source2));

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

ObjectHelper.requireNonNull(source3, "source3 is null");
ObjectHelper.requireNonNull(source4, "source4 is null");
return mergeDelayError(Flowable.fromArray(source1, source2, source3, source4));

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

@Test
public void mergeDelayErrorPublisher() {
  Single.mergeDelayError(Flowable.just(
      Single.just(1),
      Single.<Integer>error(new TestException()),
      Single.just(2))
  )
  .test()
  .assertFailure(TestException.class, 1, 2);
}

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

@Test
  public void mergeDelayError4() {
    Single.mergeDelayError(
        Single.just(1),
        Single.<Integer>error(new TestException()),
        Single.just(2),
        Single.just(3)
    )
    .test()
    .assertFailure(TestException.class, 1, 2, 3);
  }
}

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

ObjectHelper.requireNonNull(source2, "source2 is null");
ObjectHelper.requireNonNull(source3, "source3 is null");
return mergeDelayError(Flowable.fromArray(source1, source2, source3));

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

ObjectHelper.requireNonNull(source3, "source3 is null");
ObjectHelper.requireNonNull(source4, "source4 is null");
return mergeDelayError(Flowable.fromArray(source1, source2, source3, source4));