@@ -5577,14 +5577,16 @@ public final void forEach(final Action1<? super T> onNext, final Action1<Throwab
5577
5577
5578
5578
/**
5579
5579
* Groups the items emitted by an {@code Observable} according to a specified criterion, and emits these
5580
- * grouped items as {@link GroupedObservable}s, one {@code GroupedObservable} per group.
5580
+ * grouped items as {@link GroupedObservable}s, one {@code GroupedObservable} per group. If a {@code GroupedObservable}
5581
+ * terminates before the source terminates then the next emission by the source with the same key as the
5582
+ * {@code GroupedObservable} will cause the {@code GroupedObservable} to be resubscribed to.
5581
5583
* <p>
5582
5584
* <img width="640" height="360" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/groupBy.png" alt="">
5583
5585
* <p>
5584
5586
* <em>Note:</em> A {@link GroupedObservable} will cache the items it is to emit until such time as it
5585
5587
* is subscribed to. For this reason, in order to avoid memory leaks, you should not simply ignore those
5586
5588
* {@code GroupedObservable}s that do not concern you. Instead, you can signal to them that they may
5587
- * discard their buffers by applying an operator like {@link #take}{@code (0) } to them.
5589
+ * discard their buffers by applying an operator like {@link #ignoreElements } to them.
5588
5590
* <dl>
5589
5591
* <dt><b>Scheduler:</b></dt>
5590
5592
* <dd>{@code groupBy} does not operate by default on a particular {@link Scheduler}.</dd>
@@ -5609,7 +5611,9 @@ public final <K, R> Observable<GroupedObservable<K, R>> groupBy(final Func1<? su
5609
5611
5610
5612
/**
5611
5613
* Groups the items emitted by an {@code Observable} according to a specified criterion, and emits these
5612
- * grouped items as {@link GroupedObservable}s, one {@code GroupedObservable} per group.
5614
+ * grouped items as {@link GroupedObservable}s, one {@code GroupedObservable} per group. If a {@code GroupedObservable}
5615
+ * terminates before the source terminates then the next emission by the source with the same key as the
5616
+ * {@code GroupedObservable} will cause the {@code GroupedObservable} to be resubscribed to.
5613
5617
* <p>
5614
5618
* <img width="640" height="360" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/groupBy.png" alt="">
5615
5619
* <p>
0 commit comments