A utility library for converting node streams to Prescription FRP Observables