Fixes for streaming mode

 * we were not too careful about pushing results through the operator graph in-order, which created some problems and incorrect results
 * there was also an issue with pausing the PushProducer