如何從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上發出錯誤。