RxJS/Most Observable可以集成吗？

Question

我希望能够使用Observable库的排序来与我的系统的其他部分集成。

它看起来像Observables流将很好地工作与gun。 :)

Answer 1

它看起来像一个叫@ctrlplusb的家伙;）为此做了扩展：https://github.com/ctrlplusb/gun-most。好一个！

Answer 2

除了使用库集成，另一种解决方案是从Gun实例构建自己的Observable。看到这个codeandbox例如：https://codesandbox.io/s/pYj4OM8m1

const user$ = name => // returns a new observable 
    Observable.create(o => 
    gun.get(name).on(v => { 
     o.next(v); // passes any new values to the observers 
     console.log(v); 
    }), 
); 

// now you can do rx stuff on the stream of values 
user$('something')) 
     .map(({ name }) => ({ name: name.toUpperCase() })) 
     .filter(({ name }) => name.length > 0)