Skip to content

Commit 0c4f5c1

Browse files
authored
2.x: Improve subjects and processors package doc (#6434)
1 parent 0bb7b4d commit 0c4f5c1

File tree

2 files changed

+21
-3
lines changed

2 files changed

+21
-3
lines changed

src/main/java/io/reactivex/processors/package-info.java

Lines changed: 20 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,25 @@
1515
*/
1616

1717
/**
18-
* Classes extending the Flowable base reactive class and implementing
19-
* the Subscriber interface at the same time (aka hot Flowables).
18+
* Classes representing so-called hot backpressure-aware sources, aka <strong>processors</strong>,
19+
* that implement the {@link FlowableProcessor} class,
20+
* the Reactive Streams {@link org.reactivestreams.Processor Processor} interface
21+
* to allow forms of multicasting events to one or more subscribers as well as consuming another
22+
* Reactive Streams {@link org.reactivestreams.Publisher Publisher}.
23+
* <p>
24+
* Available processor implementations:
25+
* <br>
26+
* <ul>
27+
* <li>{@link io.reactivex.processors.AsyncProcessor AsyncProcessor} - replays the very last item</li>
28+
* <li>{@link io.reactivex.processors.BehaviorProcessor BehaviorProcessor} - remembers the latest item</li>
29+
* <li>{@link io.reactivex.processors.MulticastProcessor MulticastProcessor} - coordinates its source with its consumers</li>
30+
* <li>{@link io.reactivex.processors.PublishProcessor PublishProcessor} - dispatches items to current consumers</li>
31+
* <li>{@link io.reactivex.processors.ReplayProcessor ReplayProcessor} - remembers some or all items and replays them to consumers</li>
32+
* <li>{@link io.reactivex.processors.UnicastProcessor UnicastProcessor} - remembers or relays items to a single consumer</li>
33+
* </ul>
34+
* <p>
35+
* The non-backpressured variants of the {@code FlowableProcessor} class are called
36+
* {@link io.reactivex.Subject}s and reside in the {@code io.reactivex.subjects} package.
37+
* @see io.reactivex.subjects
2038
*/
2139
package io.reactivex.processors;

src/main/java/io/reactivex/subjects/package-info.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@
2929
* <br>&nbsp;&nbsp;&nbsp;{@link io.reactivex.subjects.BehaviorSubject BehaviorSubject}
3030
* <br>&nbsp;&nbsp;&nbsp;{@link io.reactivex.subjects.PublishSubject PublishSubject}
3131
* <br>&nbsp;&nbsp;&nbsp;{@link io.reactivex.subjects.ReplaySubject ReplaySubject}
32-
* <br>&nbsp;&nbsp;&nbsp;{@link io.reactivex.subjects.UnicastSubject UnicastSubjectSubject}
32+
* <br>&nbsp;&nbsp;&nbsp;{@link io.reactivex.subjects.UnicastSubject UnicastSubject}
3333
* </td>
3434
* <td>{@link io.reactivex.Observable Observable}</td>
3535
* <td>{@link io.reactivex.Observer Observer}</td>

0 commit comments

Comments
 (0)