Skip to content

Commit 3656b9b

Browse files
serj-lotutoviciakarnokd
authored andcommitted
2x: Fix wording in Async and Publish processors javadoc. (#5444)
1 parent 14a83b3 commit 3656b9b

File tree

2 files changed

+7
-6
lines changed

2 files changed

+7
-6
lines changed

src/main/java/io/reactivex/processors/AsyncProcessor.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,8 @@
2121
import org.reactivestreams.*;
2222

2323
/**
24-
* A Subject that emits the very last value followed by a completion event or the received error to Subscribers.
24+
* Processor that emits the very last value followed by a completion event or the received error
25+
* to {@link Subscriber}s.
2526
*
2627
* <p>The implementation of onXXX methods are technically thread-safe but non-serialized calls
2728
* to them may lead to undefined state in the currently subscribed Subscribers.

src/main/java/io/reactivex/processors/PublishProcessor.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -23,14 +23,14 @@
2323
import io.reactivex.plugins.RxJavaPlugins;
2424

2525
/**
26-
* A Subject that multicasts events to Subscribers that are currently subscribed to it.
26+
* Processor that multicasts all subsequently observed items to its current {@link Subscriber}s.
2727
*
2828
* <p>
2929
* <img width="640" height="405" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/S.PublishSubject.png" alt="">
3030
*
31-
* <p>The subject does not coordinate backpressure for its subscribers and implements a weaker onSubscribe which
32-
* calls requests Long.MAX_VALUE from the incoming Subscriptions. This makes it possible to subscribe the PublishSubject
33-
* to multiple sources (note on serialization though) unlike the standard contract on Subscriber. Child subscribers, however, are not overflown but receive an
31+
* <p>The processor does not coordinate backpressure for its subscribers and implements a weaker onSubscribe which
32+
* calls requests Long.MAX_VALUE from the incoming Subscriptions. This makes it possible to subscribe the PublishProcessor
33+
* to multiple sources (note on serialization though) unlike the standard Subscriber contract. Child subscribers, however, are not overflown but receive an
3434
* IllegalStateException in case their requested amount is zero.
3535
*
3636
* <p>The implementation of onXXX methods are technically thread-safe but non-serialized calls
@@ -54,7 +54,7 @@
5454
processor.onComplete();
5555
5656
} </pre>
57-
* @param <T> the value type multicast to Subscribers.
57+
* @param <T> the value type multicasted to Subscribers.
5858
*/
5959
public final class PublishProcessor<T> extends FlowableProcessor<T> {
6060
/** The terminated indicator for the subscribers array. */

0 commit comments

Comments
 (0)