rxjs 获取正在输入的人员列表答案

【问题标题】：rxjs get list of people typingrxjs 获取正在输入的人员列表
【发布时间】：2019-01-01 09:04:04
【问题描述】：

我的应用程序中有一个消息传递系统，它使用 socket-io 允许用户互相发送即时消息。

我有一项服务可以检测他们何时输入。

const userTyping = this.instantMessageService
  .messageTyping;

userTyping.subscribe(message => console.log(message.username))

我希望其他用户能够看到谁在给他们输入超时消息的列表。

因此，如果有人开始输入，他们将看到“John Doe 正在输入消息” - 这将在几秒钟后超时。

与此同时，如果其他用户开始输入，他们将看到“John Doe 和 Bill Bloggs 正在输入消息”等等。

我尝试过在 rxjs 中处理合并、窗口、缓冲区等，但似乎无法将它们结合在一起。

有人有什么建议吗？

【问题讨论】：

【解决方案1】：

您可以将结果推送到一个数组并映射并抛出它以显示谁在输入

【讨论】：

【解决方案2】：

尝试使用[reduce][1] 并在reduce 中连接项目。

【讨论】：