You could also express it as a query over a comonadic stream.