File tree Expand file tree Collapse file tree 1 file changed +4
-5
lines changed
src/main/java/io/reactivex Expand file tree Collapse file tree 1 file changed +4
-5
lines changed Original file line number Diff line number Diff line change @@ -1748,18 +1748,17 @@ public static <T> Observable<T> fromIterable(Iterable<? extends T> source) {
1748
1748
}
1749
1749
1750
1750
/**
1751
- * Converts an arbitrary Reactive-Streams ObservableSource into a Observable if not already a
1752
- * Observable.
1751
+ * Converts an arbitrary Reactive-Streams Publisher into an Observable.
1753
1752
* <dl>
1754
1753
* <dt><b>Scheduler:</b></dt>
1755
- * <dd>{@code fromObservableSource } does not operate by default on a particular {@link Scheduler}.</dd>
1754
+ * <dd>{@code fromPublisher } does not operate by default on a particular {@link Scheduler}.</dd>
1756
1755
* </dl>
1757
1756
* @param <T> the value type of the flow
1758
- * @param publisher the ObservableSource to convert
1757
+ * @param publisher the Publisher to convert
1759
1758
* @return the new Observable instance
1760
1759
* @throws NullPointerException if publisher is null
1761
1760
*/
1762
- public static <T> Observable<T> fromObservableSource(final Publisher<? extends T> publisher) {
1761
+ public static <T> Observable<T> fromPublisher( Publisher<? extends T> publisher) {
1763
1762
Objects.requireNonNull(publisher, "publisher is null");
1764
1763
return new ObservableFromPublisher<T>(publisher);
1765
1764
}
You can’t perform that action at this time.
0 commit comments