Makes RxJS Subjects graceful. Why? Because...
- Exceptions usually terminate Subjects and often swallow errors.
- It's naive to be confident our code does not contain an exception.
npm install rx-graceful
'use strict'
const Rx = require('rxjs')
require('rx-graceful')(Rx)
const $ = new Rx.Subject()
$
// (1) catches exceptions inside map
.map(() => { throw Error() })
// (2) catches rejections inside flatMap
.flatMap(x => Promise.reject())
// (3) catches exceptions inside async functions (as these are rejections as well)
.flatMap(async x => { throw Error() })
.subscribe(x => {
// (4) catches exceptions inside the subscription handler
throw Error()
}, e => {
// Handles errors (1), (2), (3), (4)
})
$.next('some value')- Use lettable operators instead of mutating
Subject.prototype, as soon as they're out of beta