callbag-subscribe 👜
A callbag sink (listener) that connects an Observer a-la RxJS.
npm install callbag-subscribe
Usage:
Simple (next only)
;;; const source = ; ; // 0// 1// 2// 3// 4// 5// 6// 7// 8// 9
Complete observer
;;; const source = ; ; // 0// 1// 2// 3// 4// 5// 6// 7// 8// 9// Done!
Disposal
Use the returned disposal function to terminate the subscription.
const source = ; const dispose = ; // Do some stuff... ; // Terminate the subscription.