Skip to content

Commit

Permalink
2.x: Fix O.blockingIterable(int) & add O.blockingLatest marbles (#5826)
Browse files Browse the repository at this point in the history
  • Loading branch information
akarnokd authored Jan 30, 2018
1 parent 3f6e595 commit b8380e2
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion src/main/java/io/reactivex/Observable.java
Original file line number Diff line number Diff line change
Expand Up @@ -5078,7 +5078,7 @@ public final Iterable<T> blockingIterable() {
/**
* Converts this {@code Observable} into an {@link Iterable}.
* <p>
* <img width="640" height="315" src="https://github.com/ReactiveX/RxJava/wiki/images/rx-operators/B.toIterable.png" alt="">
* <img width="640" height="315" src="https://github.com/ReactiveX/RxJava/wiki/images/rx-operators/blockingIterable.o.png" alt="">
* <dl>
* <dt><b>Scheduler:</b></dt>
* <dd>{@code blockingIterable} does not operate by default on a particular {@link Scheduler}.</dd>
Expand Down Expand Up @@ -5151,6 +5151,8 @@ public final T blockingLast(T defaultItem) {
* Returns an {@link Iterable} that returns the latest item emitted by this {@code Observable},
* waiting if necessary for one to become available.
* <p>
* <img width="640" height="350" src="https://github.com/ReactiveX/RxJava/wiki/images/rx-operators/blockingLatest.o.png" alt="">
* <p>
* If this {@code Observable} produces items faster than {@code Iterator.next} takes them,
* {@code onNext} events might be skipped, but {@code onError} or {@code onComplete} events are not.
* <p>
Expand Down

0 comments on commit b8380e2

Please sign in to comment.