stream: port across stream functions from datum
flow: port across flow operators from datum