diff --git a/src/main/java/io/reactivex/processors/AsyncProcessor.java b/src/main/java/io/reactivex/processors/AsyncProcessor.java index 67e6b7f6a8c..d67b1bf8434 100644 --- a/src/main/java/io/reactivex/processors/AsyncProcessor.java +++ b/src/main/java/io/reactivex/processors/AsyncProcessor.java @@ -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. + * A 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 * to them may lead to undefined state in the currently subscribed Subscribers. diff --git a/src/main/java/io/reactivex/processors/PublishProcessor.java b/src/main/java/io/reactivex/processors/PublishProcessor.java index 554632c0e6b..51ff0f63262 100644 --- a/src/main/java/io/reactivex/processors/PublishProcessor.java +++ b/src/main/java/io/reactivex/processors/PublishProcessor.java @@ -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. * *

* * - *

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 + *

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. * *

The implementation of onXXX methods are technically thread-safe but non-serialized calls @@ -54,7 +54,7 @@ processor.onComplete(); } - * @param the value type multicast to Subscribers. + * @param the value type multicasted to Subscribers. */ public final class PublishProcessor extends FlowableProcessor { /** The terminated indicator for the subscribers array. */