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)
我希望能够使用某种 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)