observable as a pull-stream source to take advantage of existing throughs and sinks