Stream graph implementation