prototype task streaming with a producer, couplers, and a sink