diff --git a/src/main/java/io/reactivex/processors/AsyncProcessor.java b/src/main/java/io/reactivex/processors/AsyncProcessor.java index c728d9eb1b..57ad766e5a 100644 --- a/src/main/java/io/reactivex/processors/AsyncProcessor.java +++ b/src/main/java/io/reactivex/processors/AsyncProcessor.java @@ -25,8 +25,10 @@ /** * Processor that emits the very last value followed by a completion event or the received error * to {@link Subscriber}s. - * - *

The implementation of onXXX methods are technically thread-safe but non-serialized calls + *

+ * + *

+ * The implementation of onXXX methods are technically thread-safe but non-serialized calls * to them may lead to undefined state in the currently subscribed Subscribers. * * @param the value type diff --git a/src/main/java/io/reactivex/processors/PublishProcessor.java b/src/main/java/io/reactivex/processors/PublishProcessor.java index 88781c45eb..92af846040 100644 --- a/src/main/java/io/reactivex/processors/PublishProcessor.java +++ b/src/main/java/io/reactivex/processors/PublishProcessor.java @@ -27,7 +27,7 @@ * Processor that multicasts all subsequently observed items to its current {@link Subscriber}s. * *

- * + * * *

The processor does not coordinate backpressure for its subscribers and implements a weaker onSubscribe which * calls requests Long.MAX_VALUE from the incoming Subscriptions. This makes it possible to subscribe the PublishProcessor diff --git a/src/main/java/io/reactivex/processors/ReplayProcessor.java b/src/main/java/io/reactivex/processors/ReplayProcessor.java index d4aeba6ebb..ac6a6c240d 100644 --- a/src/main/java/io/reactivex/processors/ReplayProcessor.java +++ b/src/main/java/io/reactivex/processors/ReplayProcessor.java @@ -30,8 +30,31 @@ /** * Replays events to Subscribers. *

- * - * + * The {@code ReplayProcessor} supports the following item retainment strategies: + *

*

* The ReplayProcessor can be created in bounded and unbounded mode. It can be bounded by * size (maximum number of elements retained at most) and/or time (maximum age of elements replayed). diff --git a/src/main/java/io/reactivex/subjects/AsyncSubject.java b/src/main/java/io/reactivex/subjects/AsyncSubject.java index 581ec9e8c9..e447ee08ac 100644 --- a/src/main/java/io/reactivex/subjects/AsyncSubject.java +++ b/src/main/java/io/reactivex/subjects/AsyncSubject.java @@ -26,6 +26,8 @@ /** * A Subject that emits the very last value followed by a completion event or the received error to Observers. *

+ * + *

* This subject does not have a public constructor by design; a new empty instance of this * {@code AsyncSubject} can be created via the {@link #create()} method. *

diff --git a/src/main/java/io/reactivex/subjects/CompletableSubject.java b/src/main/java/io/reactivex/subjects/CompletableSubject.java index c1862a6f51..69e25be91d 100644 --- a/src/main/java/io/reactivex/subjects/CompletableSubject.java +++ b/src/main/java/io/reactivex/subjects/CompletableSubject.java @@ -24,6 +24,8 @@ /** * Represents a hot Completable-like source and consumer of events similar to Subjects. *

+ * + *

* This subject does not have a public constructor by design; a new non-terminated instance of this * {@code CompletableSubject} can be created via the {@link #create()} method. *

diff --git a/src/main/java/io/reactivex/subjects/MaybeSubject.java b/src/main/java/io/reactivex/subjects/MaybeSubject.java index d6f84254f2..629e63312b 100644 --- a/src/main/java/io/reactivex/subjects/MaybeSubject.java +++ b/src/main/java/io/reactivex/subjects/MaybeSubject.java @@ -24,6 +24,8 @@ /** * Represents a hot Maybe-like source and consumer of events similar to Subjects. *

+ * + *

* This subject does not have a public constructor by design; a new non-terminated instance of this * {@code MaybeSubject} can be created via the {@link #create()} method. *

diff --git a/src/main/java/io/reactivex/subjects/PublishSubject.java b/src/main/java/io/reactivex/subjects/PublishSubject.java index 957b2a0ac6..6a13ffdd2a 100644 --- a/src/main/java/io/reactivex/subjects/PublishSubject.java +++ b/src/main/java/io/reactivex/subjects/PublishSubject.java @@ -25,7 +25,7 @@ * A Subject that emits (multicasts) items to currently subscribed {@link Observer}s and terminal events to current * or late {@code Observer}s. *

- * + * *

* This subject does not have a public constructor by design; a new empty instance of this * {@code PublishSubject} can be created via the {@link #create()} method. diff --git a/src/main/java/io/reactivex/subjects/ReplaySubject.java b/src/main/java/io/reactivex/subjects/ReplaySubject.java index d23756b785..2cdc5cb04a 100644 --- a/src/main/java/io/reactivex/subjects/ReplaySubject.java +++ b/src/main/java/io/reactivex/subjects/ReplaySubject.java @@ -29,23 +29,36 @@ /** * Replays events (in a configurable bounded or unbounded manner) to current and late {@link Observer}s. *

- * - *

* This subject does not have a public constructor by design; a new empty instance of this * {@code ReplaySubject} can be created via the following {@code create} methods that * allow specifying the retention policy for items: *

*

* Since a {@code Subject} is conceptionally derived from the {@code Processor} type in the Reactive Streams specification, diff --git a/src/main/java/io/reactivex/subjects/SingleSubject.java b/src/main/java/io/reactivex/subjects/SingleSubject.java index d3b4cf63c3..f904662004 100644 --- a/src/main/java/io/reactivex/subjects/SingleSubject.java +++ b/src/main/java/io/reactivex/subjects/SingleSubject.java @@ -24,6 +24,8 @@ /** * Represents a hot Single-like source and consumer of events similar to Subjects. *

+ * + *

* This subject does not have a public constructor by design; a new non-terminated instance of this * {@code SingleSubject} can be created via the {@link #create()} method. *