io.reactivex.Flowable.repeatUntil()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(9.4k)|赞(0)|评价(0)|浏览(187)

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

Flowable.repeatUntil介绍

[英]Returns a Flowable that repeats the sequence of items emitted by the source Publisher until the provided stop function returns true.

Backpressure: The operator honors downstream backpressure and expects the source Publisher to honor backpressure as well. If this expectation is violated, the operator may throw an IllegalStateException. Scheduler: repeatUntil does not operate by default on a particular Scheduler.
[中]返回一个可流动函数，该函数重复源发布服务器发出的项目序列，直到提供的停止函数返回true为止。
背压：操作员接受下游背压，并希望源发布者也接受背压。如果违反此期望，运算符可能抛出一个非法状态异常。调度程序：默认情况下，repeatUntil不会在特定调度程序上运行。

代码示例

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

  1. @Test(expected = NullPointerException.class)
  2. public void repeatUntilNull() {
  3.   just1.repeatUntil(null);
  4. }

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

  1. /**
  2.  * Returns a Completable that repeatedly subscribes to this Completable so long as the given
  3.  * stop supplier returns false.
  4.  * <p>
  5.  * <img width="640" height="381" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Completable.repeatUntil.png" alt="">
  6.  * <dl>
  7.  *  <dt><b>Scheduler:</b></dt>
  8.  *  <dd>{@code repeatUntil} does not operate by default on a particular {@link Scheduler}.</dd>
  9.  * </dl>
  10.  * @param stop the supplier that should return true to stop resubscribing.
  11.  * @return the new Completable instance
  12.  * @throws NullPointerException if stop is null
  13.  */
  14. @CheckReturnValue
  15. @SchedulerSupport(SchedulerSupport.NONE)
  16. public final Completable repeatUntil(BooleanSupplier stop) {
  17.   return fromPublisher(toFlowable().repeatUntil(stop));
  18. }

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

  1. /**
  2.  * Re-subscribes to the current Single until the given BooleanSupplier returns true.
  3.  * <p>
  4.  * <img width="640" height="463" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/Single.repeatUntil.png" alt="">
  5.  * <dl>
  6.  *  <dt><b>Backpressure:</b></dt>
  7.  *  <dd>The returned {@code Flowable} honors the backpressure of the downstream consumer.</dd>
  8.  * <dt><b>Scheduler:</b></dt>
  9.  * <dd>{@code repeatUntil} does not operate by default on a particular {@link Scheduler}.</dd>
  10.  * </dl>
  11.  * @param stop the BooleanSupplier called after the current Single succeeds and if returns false,
  12.  *             the Single is re-subscribed; otherwise the sequence completes.
  13.  * @return the new Flowable instance
  14.  * @since 2.0
  15.  */
  16. @BackpressureSupport(BackpressureKind.FULL)
  17. @CheckReturnValue
  18. @SchedulerSupport(SchedulerSupport.NONE)
  19. public final Flowable<T> repeatUntil(BooleanSupplier stop) {
  20.   return toFlowable().repeatUntil(stop);
  21. }

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

  1. /**
  2.  * Returns a Flowable that repeats the sequence of items emitted by the source Maybe until
  3.  * the provided stop function returns true.
  4.  * <p>
  5.  * <img width="640" height="310" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/repeat.on.png" alt="">
  6.  * <dl>
  7.  *  <dt><b>Backpressure:</b></dt>
  8.  *  <dd>This operator honors downstream backpressure.</dd>
  9.  *  <dt><b>Scheduler:</b></dt>
  10.  *  <dd>{@code repeatUntil} does not operate by default on a particular {@link Scheduler}.</dd>
  11.  * </dl>
  12.  *
  13.  * @param stop
  14.  *                a boolean supplier that is called when the current Flowable completes and unless it returns
  15.  *                false, the current Flowable is resubscribed
  16.  * @return the new Flowable instance
  17.  * @throws NullPointerException
  18.  *             if {@code stop} is null
  19.  * @see <a href="http://reactivex.io/documentation/operators/repeat.html">ReactiveX operators documentation: Repeat</a>
  20.  */
  21. @BackpressureSupport(BackpressureKind.FULL)
  22. @CheckReturnValue
  23. @SchedulerSupport(SchedulerSupport.NONE)
  24. public final Flowable<T> repeatUntil(BooleanSupplier stop) {
  25.   return toFlowable().repeatUntil(stop);
  26. }

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

  1. /**
  2.  * Returns a Completable that repeatedly subscribes to this Completable so long as the given
  3.  * stop supplier returns false.
  4.  * <dl>
  5.  *  <dt><b>Scheduler:</b></dt>
  6.  *  <dd>{@code repeatUntil} does not operate by default on a particular {@link Scheduler}.</dd>
  7.  * </dl>
  8.  * @param stop the supplier that should return true to stop resubscribing.
  9.  * @return the new Completable instance
  10.  * @throws NullPointerException if stop is null
  11.  */
  12. @CheckReturnValue
  13. @SchedulerSupport(SchedulerSupport.NONE)
  14. public final Completable repeatUntil(BooleanSupplier stop) {
  15.   return fromPublisher(toFlowable().repeatUntil(stop));
  16. }

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

  1. /**
  2.  * Re-subscribes to the current Single until the given BooleanSupplier returns true.
  3.  * <dl>
  4.  *  <dt><b>Backpressure:</b></dt>
  5.  *  <dd>The returned {@code Flowable} honors the backpressure of the downstream consumer.</dd>
  6.  * <dt><b>Scheduler:</b></dt>
  7.  * <dd>{@code repeatUntil} does not operate by default on a particular {@link Scheduler}.</dd>
  8.  * </dl>
  9.  * @param stop the BooleanSupplier called after the current Single succeeds and if returns false,
  10.  *             the Single is re-subscribed; otherwise the sequence completes.
  11.  * @return the new Flowable instance
  12.  * @since 2.0
  13.  */
  14. @BackpressureSupport(BackpressureKind.FULL)
  15. @CheckReturnValue
  16. @SchedulerSupport(SchedulerSupport.NONE)
  17. public final Flowable<T> repeatUntil(BooleanSupplier stop) {
  18.   return toFlowable().repeatUntil(stop);
  19. }

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

  1. @Test
  2. public void repeatUntilSupplierCrash() {
  3.   Flowable.just(1)
  4.   .repeatUntil(new BooleanSupplier() {
  5.     @Override
  6.     public boolean getAsBoolean() throws Exception {
  7.       throw new TestException();
  8.     }
  9.   })
  10.   .test()
  11.   .assertFailure(TestException.class, 1);
  12. }

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

  1. /**
  2.  * Returns a Flowable that repeats the sequence of items emitted by the source Maybe until
  3.  * the provided stop function returns true.
  4.  * <p>
  5.  * <img width="640" height="310" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/repeat.on.png" alt="">
  6.  * <dl>
  7.  *  <dt><b>Backpressure:</b></dt>
  8.  *  <dd>This operator honors downstream backpressure.</dd>
  9.  *  <dt><b>Scheduler:</b></dt>
  10.  *  <dd>{@code repeatUntil} does not operate by default on a particular {@link Scheduler}.</dd>
  11.  * </dl>
  12.  *
  13.  * @param stop
  14.  *                a boolean supplier that is called when the current Flowable completes and unless it returns
  15.  *                false, the current Flowable is resubscribed
  16.  * @return the new Flowable instance
  17.  * @throws NullPointerException
  18.  *             if {@code stop} is null
  19.  * @see <a href="http://reactivex.io/documentation/operators/repeat.html">ReactiveX operators documentation: Repeat</a>
  20.  */
  21. @BackpressureSupport(BackpressureKind.FULL)
  22. @CheckReturnValue
  23. @SchedulerSupport(SchedulerSupport.NONE)
  24. public final Flowable<T> repeatUntil(BooleanSupplier stop) {
  25.   return toFlowable().repeatUntil(stop);
  26. }

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

  1. @Test
  2. public void repeatUntilFalse() {
  3.   Flowable.just(1)
  4.   .repeatUntil(new BooleanSupplier() {
  5.     @Override
  6.     public boolean getAsBoolean() throws Exception {
  7.       return true;
  8.     }
  9.   })
  10.   .test()
  11.   .assertResult(1);
  12. }

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

  1. @Test
  2. public void repeatUntilCancel() {
  3.   Flowable.just(1)
  4.   .repeatUntil(new BooleanSupplier() {
  5.     @Override
  6.     public boolean getAsBoolean() throws Exception {
  7.       return true;
  8.     }
  9.   })
  10.   .test(2L, true)
  11.   .assertEmpty();
  12. }

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

  1. @Test
  2. public void noCancelPreviousRepeatUntil() {
  3.   final AtomicInteger counter = new AtomicInteger();
  4.   Flowable<Integer> source = Flowable.just(1).doOnCancel(new Action() {
  5.     @Override
  6.     public void run() throws Exception {
  7.       counter.getAndIncrement();
  8.     }
  9.   });
  10.   final AtomicInteger times = new AtomicInteger();
  11.   source.repeatUntil(new BooleanSupplier() {
  12.     @Override
  13.     public boolean getAsBoolean() throws Exception {
  14.       return times.getAndIncrement() == 4;
  15.     }
  16.   })
  17.   .test()
  18.   .assertResult(1, 1, 1, 1, 1);
  19.   assertEquals(0, counter.get());
  20. }

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

  1. @Test
  2. public void repeatUntilError() {
  3.   Flowable.error(new TestException())
  4.   .repeatUntil(new BooleanSupplier() {
  5.     @Override
  6.     public boolean getAsBoolean() throws Exception {
  7.       return true;
  8.     }
  9.   })
  10.   .test()
  11.   .assertFailure(TestException.class);
  12. }

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

  1. @Test
  2. public void repeatUntil() {
  3.   Flowable.just(1)
  4.   .repeatUntil(new BooleanSupplier() {
  5.     @Override
  6.     public boolean getAsBoolean() throws Exception {
  7.       return false;
  8.     }
  9.   })
  10.   .take(5)
  11.   .test()
  12.   .assertResult(1, 1, 1, 1, 1);
  13. }

代码示例来源：origin: akarnokd/RxJava2Extensions

  1. /**
  2.  * Repeats this Perhaps until the given boolean supplier returns true when an
  3.  * repeat iteration of this Perhaps completes.
  4.  * @param stop the supplier of a boolean value that should return true to
  5.  * stop repeating.
  6.  * @return the new Flowable instance
  7.  */
  8. public final Flowable<T> repeat(BooleanSupplier stop) {
  9.   return Flowable.fromPublisher(this).repeatUntil(stop);
  10. }

代码示例来源：origin: com.github.akarnokd/rxjava2-extensions

  1. /**
  2.  * Repeats this Perhaps until the given boolean supplier returns true when an
  3.  * repeat iteration of this Perhaps completes.
  4.  * @param stop the supplier of a boolean value that should return true to
  5.  * stop repeating.
  6.  * @return the new Flowable instance
  7.  */
  8. public final Flowable<T> repeat(BooleanSupplier stop) {
  9.   return Flowable.fromPublisher(this).repeatUntil(stop);
  10. }

代码示例来源：origin: akarnokd/RxJava2Extensions

  1. /**
  2.  * Repeats this Solo until the given boolean supplier returns true when an
  3.  * repeat iteration of this Solo completes.
  4.  * @param stop the supplier of a boolean value that should return true to
  5.  * stop repeating.
  6.  * @return the new Flowable instance
  7.  */
  8. public final Flowable<T> repeat(BooleanSupplier stop) {
  9.   return Flowable.fromPublisher(this).repeatUntil(stop);
  10. }

代码示例来源：origin: com.github.akarnokd/rxjava2-extensions

  1. /**
  2.  * Repeats this Solo until the given boolean supplier returns true when an
  3.  * repeat iteration of this Solo completes.
  4.  * @param stop the supplier of a boolean value that should return true to
  5.  * stop repeating.
  6.  * @return the new Flowable instance
  7.  */
  8. public final Flowable<T> repeat(BooleanSupplier stop) {
  9.   return Flowable.fromPublisher(this).repeatUntil(stop);
  10. }

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

Flowable

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Flowable类方法

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