prototyping streams over connection modules :ocean: