我的应用程序中有一个消息传递系统,它使用socket-io允许用户向对方发送即时消息。
我有一个服务,可以检测他们何时打字。
const userTyping = this.instantMessageService
.messageTyping;
userTyping.subscribe(message => console.log(message.username))
我希望其他用户能够看到一个列表,其中列出了一个超时的消息。
因此,如果一个人开始输入,他们将看到“John Doe正在输入消息” - 这将在几秒钟后超时。
与此同时,如果其他用户开始输入,他们将看到“John Doe和Bill Bloggs正在键入消息”等等。
我已经尝试在rxjs中搞乱合并,窗口,缓冲区等,但似乎无法将它们联系在一起。
有人有任何提示吗?
您可以将结果推送到数组并映射它以显示正在键入的人
尝试使用[reduce][1]
并在reduce中连接项目。