stream¶ effectpy.stream ¶ Stream ¶ Bases: Generic[A] Minimal stream built atop Queue with termination propagation. A Stream is a function that, given an output Queue, runs producers/tasks that write to it and then closes it when done.