Wie eine RxJs beobachtbare von einem Knoten Anfrage

Question

Aktuell können eine beobachtbare erstellen explizit erstellen, wie folgt:

const Rx = require("rxjs"); 
const request = require("request"); 

     return Rx.Observable.create(function (observer) { 
      request(options, function (error, response, body) { 
       if (error) { 
        observer.error(error); 
       } else { 
        observer.next(response); 
        observer.complete(); 
       } 
      }); 
     }); 

Gibt es eine Abkürzung Weg, dies mit der RxJs Bibliothek (oder einer anderen Bibliothek) zu tun?

Answer 1

Hier ist meine Lösung:

return (options) => { 
     const boundCallback = Rx.Observable.bindNodeCallback(request, toResponseOnly); 
     return boundCallback(options); 
    }; 

function toResponseOnly(response) { 
    return response; 
} 

Die zweite Funktion ist nur die Antwort, um sicherzustellen, erforderlich ist, weitergegeben wird, da sonst die params an die Callback als ein Array weitergegeben.