callbag-from-stream
Convert a readable stream (or any EventEmitter with data / end / error events) to a callbag listenable source.
npm install callbag-from-stream
example
Create and observe a source callbag created from a file's readable stream:
const fs = ;const fromStream = ;const observe = ; const stream = fs;const source = ;source;