如何从xstream Stream上的.map（）发送错误？

Question

比方说，我想流发出在某些情况下的错误：

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上发出错误。