callbag-subject
A callbag listener sink which is also a listenable source, and maintains an internal list of listeners. Use this like you would use RxJS Subject.
npm install callbag-subject
example
First call makeSubject
to create a subject
which is then a normal callbag, so:
- Call it with args
(1, data)
to send data into the subject - Call it with args
(2, err)
to send an error into the subject - Call it with args
(2)
to make the subject complete
const observe = ;const makeSubject = ; const subject = ; ; // First observer is added immediatelysubject; // First observer is added after 2.5 seconds; // a1// a1// a1// a2// a1// a2// ...