convert long running process subscribe to a pull