Forward propagation mechanism for stream pipelines