Wie man Redux-Speicher als beobachtbar zu machen?

Question

Here wird empfohlen, den folgenden Code zu verwenden, um einen beobachtbaren Stream aus einem Redux-Speicher zu erstellen, anstatt ihn direkt zu abonnieren.

Ich kann nicht herausfinden, wie dies in Rx integriert werden kann. Wie etwas wie Observable.fromReduxStore kann mit diesem Code implementiert werden ?.

Answer 1

Für eine gibt es bereits eine Bibliothek für this, aber wenn Sie Ihre eigene mit RxJS arbeiten möchten. (Disclaimer: ungetestet)

Rx.Observable.fromReduxStore = function(store) { 
    return Observable.create((observer) => { 
    let dispose = store.subscribe(() => observer.next(store.getState())); 
    observer.next(store.getState()); 
    return dispose; 
    }); 
}; 

Als besondere Note auf der Version ab, die Sie verwenden RxJS v4 Observer verwendet onNext während v5 es next ist.