ReactiveX:Group和Buffer仅为每个组中的最后一项

如何对一个Observable进行分组,并从每个GroupedObservable中仅保留内存中最后一个发出的项目？这样每个组的行为就像BehaviorSubject一样.

像这样的东西:

{user: 1, msg: "Anyone here?"}
{user: 2, msg: "Hi"}
{user: 2, msg: "How are you?"}
{user: 1, msg: "Hello"}
{user: 1, msg: "Good"}

所以在内存中我们只有最后一项user:

{user: 2, msg: "How are you?"}
{user: 1, msg: "Good"}

当订户订阅时,这两个项目立即发布(每个项目都在其自己的排放中).就像我们每个都有BehaviorSubject一样user.

因为人们可能会永远聊天,所以onCompleted()永远不会被激发.

我事先并不知道user可以有什么价值.