Seems like errors are swallowed when stream is created out of promise. Also onError handler does not work properly. Am I misusing library or is it a bug?
const stream = kefir.fromPromise(Promise.resolve())
.map(e => {
throw new Error('This error is swallowed');
});
stream.onValue(() => {
console.log('onValue is not invoked');
});
stream.onError(() => {
console.log('onError is not invoked');
});
Seems like errors are swallowed when stream is created out of promise. Also onError handler does not work properly. Am I misusing library or is it a bug?