Skip to content

Commit b8380e2

Browse files
authored
2.x: Fix O.blockingIterable(int) & add O.blockingLatest marbles (#5826)
1 parent 3f6e595 commit b8380e2

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

src/main/java/io/reactivex/Observable.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5078,7 +5078,7 @@ public final Iterable<T> blockingIterable() {
50785078
/**
50795079
* Converts this {@code Observable} into an {@link Iterable}.
50805080
* <p>
5081-
* <img width="640" height="315" src="https://github.com/ReactiveX/RxJava/wiki/images/rx-operators/B.toIterable.png" alt="">
5081+
* <img width="640" height="315" src="https://github.com/ReactiveX/RxJava/wiki/images/rx-operators/blockingIterable.o.png" alt="">
50825082
* <dl>
50835083
* <dt><b>Scheduler:</b></dt>
50845084
* <dd>{@code blockingIterable} does not operate by default on a particular {@link Scheduler}.</dd>
@@ -5151,6 +5151,8 @@ public final T blockingLast(T defaultItem) {
51515151
* Returns an {@link Iterable} that returns the latest item emitted by this {@code Observable},
51525152
* waiting if necessary for one to become available.
51535153
* <p>
5154+
* <img width="640" height="350" src="https://github.com/ReactiveX/RxJava/wiki/images/rx-operators/blockingLatest.o.png" alt="">
5155+
* <p>
51545156
* If this {@code Observable} produces items faster than {@code Iterator.next} takes them,
51555157
* {@code onNext} events might be skipped, but {@code onError} or {@code onComplete} events are not.
51565158
* <p>

0 commit comments

Comments
 (0)