How do I listen to .once('all-unsubscribed') event? Like this one package - p-cancelable.
Otherwise, it is possible to use Subject, as in thread.js? (I wouldn't want to use Worker, as I write to SQLite as well, and it is to supposed to be written from multiple threads.)
Software engineer & creator of internet things. Node.js aficionado since 2011, React lover since 2014.
Head of solarwallet.io at SatoshiPay (satoshipay.io).
How do I listen to .once('all-unsubscribed') event?
functionsubscribeToThings(){returnmulticast(newObservable(observer=>{// <Subscribe to things>constterminateSubscription=()=>{// <-- THIS IS THE "all-unsubscribed" CODE// Remember? multicast() makes that all downstream subscriptions are bundled into one,// so this is the callback function that will be run when this bundled subscription is terminated}returnterminateSubscription}))}subscribeToThings().subscribe(/* ... */)
Otherwise, it is possible to use Subject, as in thread.js?
Software engineer & creator of internet things. Node.js aficionado since 2011, React lover since 2014.
Head of solarwallet.io at SatoshiPay (satoshipay.io).
That doesn't make much sense. Why would you want to emit a new cancellation function for every new value?
You shouldn't have this non-standard custom cancellation approach when there is already a standardized one (observable.subscribe(), subscription.unsubscribe()). Keep in mind that emitting functions is generally considered to be an anti-pattern.
Maybe the observable-fns readme lacks a link to some documentation about observables in general… I guess this is one of your first times using observables? (No offense – I'm seriously interested :) )
Software engineer & creator of internet things. Node.js aficionado since 2011, React lover since 2014.
Head of solarwallet.io at SatoshiPay (satoshipay.io).
Software engineer & creator of internet things. Node.js aficionado since 2011, React lover since 2014.
Head of solarwallet.io at SatoshiPay (satoshipay.io).
How do I listen to
.once('all-unsubscribed')
event? Like this one package - p-cancelable.Otherwise, it is possible to use
Subject
, as inthread.js
? (I wouldn't want to use Worker, as I write to SQLite as well, and it is to supposed to be written from multiple threads.)Sure, who would stop you? ;)
Currently, I use the signature,
Will it work?
That doesn't make much sense. Why would you want to emit a new cancellation function for every new value?
You shouldn't have this non-standard custom cancellation approach when there is already a standardized one (
observable.subscribe()
,subscription.unsubscribe()
). Keep in mind that emitting functions is generally considered to be an anti-pattern.Maybe the observable-fns readme lacks a link to some documentation about observables in general… I guess this is one of your first times using observables? (No offense – I'm seriously interested :) )
Yes. Only promises and eventemitters.
Should I start with RxJS?
Yeah, maybe that's the best to get started. You should definitely start with RxJS's documentation – it's pretty good!
Which library you then use doesn't really matter too much as their APIs are very similar to almost identical.
Do you actually mean
Yes, my bad! I updated my code sample accordingly.