Skip to content

Instantly share code, notes, and snippets.

@rafagsiqueira

rafagsiqueira/index.ts

Last active January 16, 2021 14:20
Show Gist options
  • Save rafagsiqueira/d5bbda3c74ec9a906bf15c51208f3668 to your computer and use it in GitHub Desktop.
Save rafagsiqueira/d5bbda3c74ec9a906bf15c51208f3668 to your computer and use it in GitHub Desktop.
Download ZIP
Example of sending emails using a stream of users
Raw
index.ts
let users$ = from(getUsers());
users$.pipe(
filter(user => user.isActive),
concatMap(user => from(sendEmail(user.email)))
).subscribe(
(success) => emailsSent++,
(err) => failedEmails++,
() = > console.log('Emails sent:'+emailsSent+' Emails failed:'+failedEmails)
)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment