Refactor all PullStreams to forward data without

buffering