Netflix/RxJava — pull request #511 by akarnokd (2013-11-22 20:53:13+00:00)
Title: Operation GroupByUntil

Issue #52

Note that Rx.NET's Subject once onCompleted() or onError()'d, any subsequent subscriptions from observers will immediately receive onCompleted() or onError(). RxJava's PublishSubject however doesn't seem to do that, leaving future observers never do anything. Since the Rx.NET.GroupByUntil relied on the described behavior to handle escaped groups, the proposed implementation inside the GroupSubject will do this manually.