Comment envoyer une erreur à partir d'un fichier .map() sur un flux xstream?

Question

Disons que je voudrais que le flux d'émettre une erreur dans certains cas:

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

J'ai trouvé que soulever une exception parvient dans les deux rxjs et 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 
           } 
          }) 

L'exception est pris par la bibliothèque Observable, et une erreur est émise sur le Stream.