@@ -3285,9 +3285,9 @@ public final <TClosing> Observable<List<T>> buffer(Func0<? extends Observable<?
3285
3285
/**
3286
3286
* Returns an Observable that emits buffers of items it collects from the source Observable. The resulting
3287
3287
* Observable emits connected, non-overlapping buffers, each containing {@code count} items. When the source
3288
- * Observable completes, the current buffer is emitted, and the event is propagated to all subscribed
3289
- * {@link Observer}s . Note that if the source {@link Observable} issues an onError notification the event
3290
- * is passed on immediately without first emitting the buffer it is in the process of assembling.
3288
+ * Observable completes, the resulting Observable emits the current buffer and propagates the notification
3289
+ * from the source Observable . Note that if the source Observable issues an onError notification
3290
+ * the event is passed on immediately without first emitting the buffer it is in the process of assembling.
3291
3291
* <p>
3292
3292
* <img width="640" height="320" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/buffer3.png" alt="">
3293
3293
* <dl>
@@ -3308,9 +3308,9 @@ public final Observable<List<T>> buffer(int count) {
3308
3308
/**
3309
3309
* Returns an Observable that emits buffers of items it collects from the source Observable. The resulting
3310
3310
* Observable emits buffers every {@code skip} items, each containing {@code count} items. When the source
3311
- * Observable completes, the current buffer is emitted, and the event is propagated to all subscribed
3312
- * {@link Observer}s . Note that if the source {@link Observable} issues an onError notification the event
3313
- * is passed on immediately without first emitting the buffer it is in the process of assembling.
3311
+ * Observable completes, the resulting Observable emits the current buffer and propagates the notification
3312
+ * from the source Observable . Note that if the source Observable issues an onError notification
3313
+ * the event is passed on immediately without first emitting the buffer it is in the process of assembling.
3314
3314
* <p>
3315
3315
* <img width="640" height="320" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/buffer4.png" alt="">
3316
3316
* <dl>
@@ -3336,9 +3336,9 @@ public final Observable<List<T>> buffer(int count, int skip) {
3336
3336
* Returns an Observable that emits buffers of items it collects from the source Observable. The resulting
3337
3337
* Observable starts a new buffer periodically, as determined by the {@code timeshift} argument. It emits
3338
3338
* each buffer after a fixed timespan, specified by the {@code timespan} argument. When the source
3339
- * Observable completes, the current buffer is emitted, and the event is propagated to all subscribed
3340
- * {@link Observer}s . Note that if the source {@link Observable} issues an onError notification the event
3341
- * is passed on immediately without first emitting the buffer it is in the process of assembling.
3339
+ * Observable completes, the resulting Observable emits the current buffer and propagates the notification
3340
+ * from the source Observable . Note that if the source Observable issues an onError notification
3341
+ * the event is passed on immediately without first emitting the buffer it is in the process of assembling.
3342
3342
* <p>
3343
3343
* <img width="640" height="320" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/buffer7.png" alt="">
3344
3344
* <dl>
@@ -3367,10 +3367,10 @@ public final Observable<List<T>> buffer(long timespan, long timeshift, TimeUnit
3367
3367
* Returns an Observable that emits buffers of items it collects from the source Observable. The resulting
3368
3368
* Observable starts a new buffer periodically, as determined by the {@code timeshift} argument, and on the
3369
3369
* specified {@code scheduler}. It emits each buffer after a fixed timespan, specified by the
3370
- * {@code timespan} argument. When the source Observable completes completes , the current buffer is emitted,
3371
- * and the event is propagated to all subscribed {@link Observer}s . Note that if the source {@link Observable}
3372
- * issues an onError notification the event is passed on immediately without first emitting the buffer it is
3373
- * in the process of assembling.
3370
+ * {@code timespan} argument. When the source Observable completes, the resulting Observable emits the current
3371
+ * buffer and propagates the notification from the source Observable . Note that if the source
3372
+ * Observable issues an onError notification the event is passed on immediately without first emitting
3373
+ * the buffer it is in the process of assembling.
3374
3374
* <p>
3375
3375
* <img width="640" height="320" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/buffer7.s.png" alt="">
3376
3376
* <dl>
@@ -3400,10 +3400,10 @@ public final Observable<List<T>> buffer(long timespan, long timeshift, TimeUnit
3400
3400
/**
3401
3401
* Returns an Observable that emits buffers of items it collects from the source Observable. The resulting
3402
3402
* Observable emits connected, non-overlapping buffers, each of a fixed duration specified by the
3403
- * {@code timespan} argument. When the source Observable completes, the current buffer is emitted,
3404
- * and the event is propagated to all subscribed {@link Observer}s . Note that if the source {@link Observable}
3405
- * issues an onError notification the event is passed on immediately without first emitting the buffer it is
3406
- * in the process of assembling.
3403
+ * {@code timespan} argument. When the source Observable completes, the resulting Observable emits the current
3404
+ * buffer and propagates the notification from the source Observable . Note that if the source
3405
+ * Observable issues an onError notification the event is passed on immediately without first emitting
3406
+ * the buffer it is in the process of assembling.
3407
3407
* <p>
3408
3408
* <img width="640" height="320" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/buffer5.png" alt="">
3409
3409
* <dl>
@@ -3431,9 +3431,9 @@ public final Observable<List<T>> buffer(long timespan, TimeUnit unit) {
3431
3431
* Returns an Observable that emits buffers of items it collects from the source Observable. The resulting
3432
3432
* Observable emits connected, non-overlapping buffers, each of a fixed duration specified by the
3433
3433
* {@code timespan} argument or a maximum size specified by the {@code count} argument (whichever is reached
3434
- * first). When the source Observable completes, the current buffer is emitted, and the event is propagated
3435
- * to all subscribed {@link Observer}s . Note that if the source {@link Observable} issues an onError
3436
- * notification the event is passed on immediately without first emitting the buffer it is in the process
3434
+ * first). When the source Observable completes, the resulting Observable emits the current buffer and propagates
3435
+ * the notification from the source Observable . Note that if the source Observable issues an onError
3436
+ * notification the event is passed on immediately without first emitting the buffer it is in the process
3437
3437
* of assembling.
3438
3438
* <p>
3439
3439
* <img width="640" height="320" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/buffer6.png" alt="">
@@ -3465,9 +3465,9 @@ public final Observable<List<T>> buffer(long timespan, TimeUnit unit, int count)
3465
3465
* Returns an Observable that emits buffers of items it collects from the source Observable. The resulting
3466
3466
* Observable emits connected, non-overlapping buffers, each of a fixed duration specified by the
3467
3467
* {@code timespan} argument as measured on the specified {@code scheduler}, or a maximum size specified by
3468
- * the {@code count} argument (whichever is reached first). When the source Observable completes, the
3469
- * current buffer is emitted, and the event is propagated to all subscribed {@link Observer}s. Note that
3470
- * if the source {@link Observable} issues an onError notification the event is passed on immediately
3468
+ * the {@code count} argument (whichever is reached first). When the source Observable completes, the resulting
3469
+ * Observable emits the current buffer and propagates the notification from the source Observable.
3470
+ * Note that if the source Observable issues an onError notification the event is passed on immediately
3471
3471
* without first emitting the buffer it is in the process of assembling.
3472
3472
* <p>
3473
3473
* <img width="640" height="320" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/buffer6.s.png" alt="">
@@ -3501,8 +3501,8 @@ public final Observable<List<T>> buffer(long timespan, TimeUnit unit, int count,
3501
3501
* Returns an Observable that emits buffers of items it collects from the source Observable. The resulting
3502
3502
* Observable emits connected, non-overlapping buffers, each of a fixed duration specified by the
3503
3503
* {@code timespan} argument and on the specified {@code scheduler}. When the source Observable completes,
3504
- * the current buffer is emitted, and the event is propagated to all subscribed {@link Observer}s. Note
3505
- * that if the source {@link Observable} issues an onError notification the event is passed on immediately
3504
+ * the resulting Observable emits the current buffer and propagates the notification from the source Observable.
3505
+ * Note that if the source Observable issues an onError notification the event is passed on immediately
3506
3506
* without first emitting the buffer it is in the process of assembling.
3507
3507
* <p>
3508
3508
* <img width="640" height="320" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/buffer5.s.png" alt="">
0 commit comments