File tree Expand file tree Collapse file tree 1 file changed +3
-1
lines changed
src/main/java/rx/subjects Expand file tree Collapse file tree 1 file changed +3
-1
lines changed Original file line number Diff line number Diff line change 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 ) {
You can’t perform that action at this time.
0 commit comments