observable - 如何从 xstream 流上的 .map() 发送错误？

Question

假设我希望 Stream 在某些情况下发出错误：

import xs from 'xstream'
//...
function transformBlah(blah) {
    if (blah.status >= 200 && blah.status < 300) {
        return blah.body
    } else {
        return new Error('I would like to send an error onto the Stream here')
    }
}
const blahTransformed$ = xs.create(new BlahProducer())
                           .map(transformBlah)

Answer 1

我发现引发异常可以在rxjs和中实现这一点xstream：

import xs from 'xstream'
//...
const blahTransformed$ = xs.create(new BlahProducer())
                           .map(blah => {
                               if (blah.status >= 200 && blah.status < 300) {
                                   return blah.body
                               } else {
                                   throw blah.status 
                               }
                           })

异常被 Observable 库捕获，并在 Stream 上发出错误。