diff --git a/src/main/java/io/reactivex/Completable.java b/src/main/java/io/reactivex/Completable.java index 994054253c..c6f61a9aaa 100644 --- a/src/main/java/io/reactivex/Completable.java +++ b/src/main/java/io/reactivex/Completable.java @@ -292,6 +292,12 @@ public static Completable concat(Publisher extends CompletableSource> sources, * * }); * + *
+ * Whenever a {@link CompletableObserver} subscribes to the returned {@code Completable}, the provided + * {@link CompletableOnSubscribe} callback is invoked with a fresh instance of a {@link CompletableEmitter} + * that will interact only with that specific {@code CompletableObserver}. If this {@code CompletableObserver} + * disposes the flow (making {@link CompletableEmitter#isDisposed} return true), + * other observers subscribed to the same returned {@code Completable} are not affected. *
+ * Whenever a {@link Subscriber} subscribes to the returned {@code Flowable}, the provided + * {@link FlowableOnSubscribe} callback is invoked with a fresh instance of a {@link FlowableEmitter} + * that will interact only with that specific {@code Subscriber}. If this {@code Subscriber} + * cancels the flow (making {@link FlowableEmitter#isCancelled} return true), + * other observers subscribed to the same returned {@code Flowable} are not affected. + *
* You should call the FlowableEmitter onNext, onError and onComplete methods in a serialized fashion. The * rest of its methods are thread-safe. *
+ * Whenever a {@link MaybeObserver} subscribes to the returned {@code Maybe}, the provided + * {@link MaybeOnSubscribe} callback is invoked with a fresh instance of a {@link MaybeEmitter} + * that will interact only with that specific {@code MaybeObserver}. If this {@code MaybeObserver} + * disposes the flow (making {@link MaybeEmitter#isDisposed} return true), + * other observers subscribed to the same returned {@code Maybe} are not affected. *
+ * Whenever an {@link Observer} subscribes to the returned {@code Observable}, the provided + * {@link ObservableOnSubscribe} callback is invoked with a fresh instance of an {@link ObservableEmitter} + * that will interact only with that specific {@code Observer}. If this {@code Observer} + * disposes the flow (making {@link ObservableEmitter#isDisposed} return true), + * other observers subscribed to the same returned {@code Observable} are not affected. + *
*
*
* You should call the ObservableEmitter's onNext, onError and onComplete methods in a serialized fashion. The
diff --git a/src/main/java/io/reactivex/Single.java b/src/main/java/io/reactivex/Single.java
index d2932cbc32..cc3bb9b3b8 100644
--- a/src/main/java/io/reactivex/Single.java
+++ b/src/main/java/io/reactivex/Single.java
@@ -501,6 +501,12 @@ public static
+ * Whenever a {@link SingleObserver} subscribes to the returned {@code Single}, the provided
+ * {@link SingleOnSubscribe} callback is invoked with a fresh instance of a {@link SingleEmitter}
+ * that will interact only with that specific {@code SingleObserver}. If this {@code SingleObserver}
+ * disposes the flow (making {@link SingleEmitter#isDisposed} return true),
+ * other observers subscribed to the same returned {@code Single} are not affected.
*
*