В моем приложении есть система обмена сообщениями, которая использует socket-io, чтобы пользователи могли отправлять мгновенные сообщения друг другу.
У меня есть служба, которая обнаруживает, когда они печатают.
const userTyping = this.instantMessageService
.messageTyping;
userTyping.subscribe(message => console.log(message.username))
Я хочу, чтобы другие пользователи могли видеть список тех, кто печатает им сообщение, время ожидания которого истекло.
Поэтому, если один человек начнет печатать, он увидит «Джон Доу печатает сообщение» - этоистечет через пару секунд.
Тем временем, если другие пользователи начнут печатать, они увидят «Джон Доу и Билл Блоггс набирают сообщение» и т. д.
У меня естьпробовал возиться с слиянием, окном, буфером и т. д. в rxjs, но не могу связать все это вместе.
Кто-нибудь получил какие-нибудь советы?