Skip to content

Commit 8e56548

Browse files
committed
Update boundary buffer documentation to change source -> supplied
The word 'source' is incorrect here, since the buffer is emitted whenever the supplied Publisher emits an item
1 parent 8a8c17b commit 8e56548

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/main/java/io/reactivex/Flowable.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6529,7 +6529,7 @@ public final <B, U extends Collection<? super T>> Flowable<U> buffer(Publisher<B
65296529
* @param <B> the value type of the boundary-providing Publisher
65306530
* @param boundaryIndicatorSupplier
65316531
* a {@link Callable} that produces a Publisher that governs the boundary between buffers.
6532-
* Whenever the source {@code Publisher} emits an item, {@code buffer} emits the current buffer and
6532+
* Whenever the supplied {@code Publisher} emits an item, {@code buffer} emits the current buffer and
65336533
* begins to fill a new one
65346534
* @return a Flowable that emits a connected, non-overlapping buffer of items from the source Publisher
65356535
* each time the Publisher created with the {@code closingIndicator} argument emits an item
@@ -6563,7 +6563,7 @@ public final <B> Flowable<List<T>> buffer(Callable<? extends Publisher<B>> bound
65636563
* @param <B> the value type of the boundary-providing Publisher
65646564
* @param boundaryIndicatorSupplier
65656565
* a {@link Callable} that produces a Publisher that governs the boundary between buffers.
6566-
* Whenever the source {@code Publisher} emits an item, {@code buffer} emits the current buffer and
6566+
* Whenever the supplied {@code Publisher} emits an item, {@code buffer} emits the current buffer and
65676567
* begins to fill a new one
65686568
* @param bufferSupplier
65696569
* a factory function that returns an instance of the collection subclass to be used and returned

0 commit comments

Comments
 (0)