static Stream<String> onTypingIndicator() { return typingStream.receiveBroadcastStream(2).map<String>((e) => e); }