Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
RxJS Socket.IO Angular Chat - Angular Component - Coding Blast - www.codingblast.com
ngOnInit() {
this.chatService
.getMessages()
.distinctUntilChanged()
.filter((message) => message.trim().length > 0)
.throttleTime(1000)
.scan((acc: string, message: string, index: number) =>
`${message}(${index + 1})`
, 1)
.subscribe((message: string) => {
const currentTime = moment().format('hh:mm:ss a');
const messageWithTimestamp = `${currentTime}: ${message}`;
this.messages.push(messageWithTimestamp);
});
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.