File tree 1 file changed +2
-2
lines changed
src/main/java/io/reactivex/processors
1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change 43
43
* the given prefetch amount and no reference counting behavior.</li>
44
44
* <li>{@link #create(boolean)}: create an empty {@code MulticastProcessor} with
45
45
* {@link io.reactivex.Flowable#bufferSize() Flowable.bufferSize()} prefetch amount
46
- * and no reference counting behavior.</li>
46
+ * and an optional reference counting behavior.</li>
47
47
* <li>{@link #create(int, boolean)}: create an empty {@code MulticastProcessor} with
48
48
* the given prefetch amount and an optional reference counting behavior.</li>
49
49
* </ul>
@@ -174,7 +174,7 @@ public static <T> MulticastProcessor<T> create() {
174
174
175
175
/**
176
176
* Constructs a fresh instance with the default Flowable.bufferSize() prefetch
177
- * amount and no refCount-behavior.
177
+ * amount and the optional refCount-behavior.
178
178
* @param <T> the input and output value type
179
179
* @param refCount if true and if all Subscribers have canceled, the upstream
180
180
* is cancelled
You can’t perform that action at this time.
0 commit comments