File tree Expand file tree Collapse file tree 1 file changed +5
-3
lines changed
src/main/java/rx/observables Expand file tree Collapse file tree 1 file changed +5
-3
lines changed Original file line number Diff line number Diff line change @@ -77,10 +77,12 @@ public static <T> BlockingObservable<T> from(final Observable<? extends T> o) {
7777 * <p>
7878 * <em>Note:</em> This will block even if the underlying Observable is asynchronous.
7979 * <p>
80- * This is similar to {@link Observable#subscribe(Subscriber)}, but it blocks. Because it blocks it does not
81- * need the {@link Subscriber#onCompleted()} or {@link Subscriber#onError(Throwable)} methods.
82- * <p>
8380 * <img width="640" height="330" src="https://github.com/ReactiveX/RxJava/wiki/images/rx-operators/B.forEach.png" alt="">
81+ * <p>
82+ * This is similar to {@link Observable#subscribe(Subscriber)}, but it blocks. Because it blocks it does not
83+ * need the {@link Subscriber#onCompleted()} or {@link Subscriber#onError(Throwable)} methods. If the
84+ * underlying Observable terminates with an error, rather than calling {@code onError}, this method will
85+ * throw an exception.
8486 *
8587 * @param onNext
8688 * the {@link Action1} to invoke for each item emitted by the {@code BlockingObservable}
You can’t perform that action at this time.
0 commit comments