Skip to content

Commit

Permalink
2x: Fix wording in Async and Publish processors javadoc.
Browse files Browse the repository at this point in the history
  • Loading branch information
serj-lotutovici committed Jun 26, 2017
1 parent 14a83b3 commit 34c4858
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 6 deletions.
3 changes: 2 additions & 1 deletion src/main/java/io/reactivex/processors/AsyncProcessor.java
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,8 @@
import org.reactivestreams.*;

/**
* A Subject that emits the very last value followed by a completion event or the received error to Subscribers.
* Processor that emits the very last value followed by a completion event or the received error
* to {@link Subscriber}s.
*
* <p>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.
Expand Down
10 changes: 5 additions & 5 deletions src/main/java/io/reactivex/processors/PublishProcessor.java
Original file line number Diff line number Diff line change
Expand Up @@ -23,14 +23,14 @@
import io.reactivex.plugins.RxJavaPlugins;

/**
* A Subject that multicasts events to Subscribers that are currently subscribed to it.
* Processor that multicasts all subsequently observed items to its current {@link Subscriber}s.
*
* <p>
* <img width="640" height="405" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/S.PublishSubject.png" alt="">
*
* <p>The subject 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 PublishSubject
* to multiple sources (note on serialization though) unlike the standard contract on Subscriber. Child subscribers, however, are not overflown but receive an
* <p>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
* to multiple sources (note on serialization though) unlike the standard Subscriber contract. Child subscribers, however, are not overflown but receive an
* IllegalStateException in case their requested amount is zero.
*
* <p>The implementation of onXXX methods are technically thread-safe but non-serialized calls
Expand All @@ -54,7 +54,7 @@
processor.onComplete();
} </pre>
* @param <T> the value type multicast to Subscribers.
* @param <T> the value type multicasted to Subscribers.
*/
public final class PublishProcessor<T> extends FlowableProcessor<T> {
/** The terminated indicator for the subscribers array. */
Expand Down

0 comments on commit 34c4858

Please sign in to comment.