Use Observables to read and push data from server pipe