Skip to content

Commit d1f20a1

Browse files
authored
1.x: add marble diagram to UnicastSubject, fix javadoc (ReactiveX#5209)
1 parent e6824c1 commit d1f20a1

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

src/main/java/rx/subjects/UnicastSubject.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,8 @@
3232
* amount. In this case, the buffered values are no longer retained. If the Subscriber
3333
* requests a limited amount, queueing is involved and only those values are retained which
3434
* weren't requested by the Subscriber at that time.
35-
*
35+
* <p>
36+
* <img width="640" height="370" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/UnicastSubject.v1.png" alt="">
3637
* @param <T> the input and output value type
3738
*/
3839
@Experimental
@@ -68,6 +69,7 @@ public static <T> UnicastSubject<T> create(int capacityHint) {
6869
* Constructs an empty UnicastSubject instance with the default capacity hint of 16 elements.
6970
*
7071
* @param delayError deliver pending next events before error.
72+
* @param <T> the input and output value type
7173
* @return the created UnicastSubject instance
7274
*/
7375
public static <T> UnicastSubject<T> create(boolean delayError) {

0 commit comments

Comments
 (0)