RxJS/Most Observable 可以集成吗?

Can RxJS/Most Observable be integrated?

我希望能够使用某种 Observables 库来与我系统的其他部分集成。

看起来 Observables 流可以很好地与 gun 一起工作。 :)

看起来像一个叫@ctrlplusb 的人 ;) 为此做了一个扩展:https://github.com/ctrlplusb/gun-most。不错!

除了使用库集成之外,另一种解决方案是从 Gun 实例构建您自己的 Observables。例如,请参阅此代码框: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)