This is an impressive piece of code. It nicely incorporates the pattern from `groupBy`. And if I understand correctly we don't have the same issue as `groupBy` where the `Observable` is never subscribed to, since this is only kicked off when the `subscribe` is happening.