↰
base.flows.FlowOp[E]
mut .isFinite: imm base.Bool -> …,
mut .step(sink: mut base.flows._Sink[E]): imm base.Void,
mut .stop: imm base.Void,
mut .isRunning: imm base.Bool,
mut .forRemaining(downstream: mut base.flows._Sink[E]): imm base.Void -> …,
mut .split: mut base.Opt[mut base.flows.FlowOp[E]] -> …,
read .canSplit: imm base.Bool -> …,
mut .isFinite: imm base.Bool -> …,
mut .step(sink: mut base.flows._Sink[E]): imm base.Void,
mut .stop: imm base.Void,
mut .isRunning: imm base.Bool,
mut .forRemaining(downstream: mut base.flows._Sink[E]): imm base.Void -> …,
mut .split: mut base.Opt[mut base.flows.FlowOp[E]] -> …,
read .canSplit: imm base.Bool -> …,