callbag-rescue
Callbag higher-order operator that rescues a failed source. Works on either pullable or listenable sources.
npm install callbag-rescue
examples
listenables
After a failed promise, rescue with a new Callbag source:
const forEach = require('callbag-for-each');
const fromPromise = require('callbag-from-promise');
const of = require('callbag-of');
const map = require('callbag-map');
const pipe = require('callbag-pipe');
const rescue = require('callbag-rescue');
pipe(
fromPromise(Promise.reject({ status: 404 })),
map(res => res.body),
rescue(err => of({ type: 'ERROR', payload: err })),
forEach(n => {
console.log(n); // { type: 'ERROR', payload: { status: 404 } }
})
);pullables
After a source Callbag throws an error, rescue it:
const forEach = require('callbag-for-each');
const fromIter = require('callbag-from-iter');
const map = require('callbag-map');
const of = require('callbag-of');
const pipe = require('callbag-pipe');
pipe(
fromIter([1, 2]),
map(num => num.a.name),
rescue(err => of({ type: 'ERROR', payload: err.message })),
forEach(n => {
console.log(n); // { type: 'ERROR', payload: 'Cannot read property "name" of undefined' }
})
);