@@ -6516,9 +6516,10 @@ public final <B, U extends Collection<? super T>> Flowable<U> buffer(Publisher<B
6516
6516
* new buffer whenever the Publisher produced by the specified {@code boundaryIndicatorSupplier} emits an item.
6517
6517
* <p>
6518
6518
* <img width="640" height="395" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/buffer1.png" alt="">
6519
- * <dl >
6520
- * If either the source Publisher or the boundary Publisher issues an onError notification the event is passed on
6519
+ * <p >
6520
+ * If either the source {@code Publisher} or the boundary {@code Publisher} issues an {@code onError} notification the event is passed on
6521
6521
* immediately without first emitting the buffer it is in the process of assembling.
6522
+ * <dl>
6522
6523
* <dt><b>Backpressure:</b></dt>
6523
6524
* <dd>This operator does not support backpressure as it is instead controlled by the given Publishers and
6524
6525
* buffers data. It requests {@code Long.MAX_VALUE} upstream and does not obey downstream requests.</dd>
@@ -6540,7 +6541,6 @@ public final <B, U extends Collection<? super T>> Flowable<U> buffer(Publisher<B
6540
6541
@SchedulerSupport(SchedulerSupport.NONE)
6541
6542
public final <B> Flowable<List<T>> buffer(Callable<? extends Publisher<B>> boundaryIndicatorSupplier) {
6542
6543
return buffer(boundaryIndicatorSupplier, ArrayListSupplier.<T>asCallable());
6543
-
6544
6544
}
6545
6545
6546
6546
/**
@@ -6549,9 +6549,10 @@ public final <B> Flowable<List<T>> buffer(Callable<? extends Publisher<B>> bound
6549
6549
* new buffer whenever the Publisher produced by the specified {@code boundaryIndicatorSupplier} emits an item.
6550
6550
* <p>
6551
6551
* <img width="640" height="395" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/buffer1.png" alt="">
6552
- * <dl >
6553
- * If either the source Publisher or the boundary Publisher issues an onError notification the event is passed on
6552
+ * <p >
6553
+ * If either the source {@code Publisher} or the boundary {@code Publisher} issues an {@code onError} notification the event is passed on
6554
6554
* immediately without first emitting the buffer it is in the process of assembling.
6555
+ * <dl>
6555
6556
* <dt><b>Backpressure:</b></dt>
6556
6557
* <dd>This operator does not support backpressure as it is instead controlled by the given Publishers and
6557
6558
* buffers data. It requests {@code Long.MAX_VALUE} upstream and does not obey downstream requests.</dd>
0 commit comments