↰
base.flows.FlowOp[E:imm,mut,read]base.flows.ActorImpl/3base.flows.ActorImplMut/3base.flows.ActorRes/0base.flows.ActorResMatch/1base.flows.EmptyFlow/1base.flows.Enumerated/1base.flows.Flow/0base.flows.Flow/1base.flows.FlowOp/1base.flows.Joinable/1base.flows.Pair/2base.flows.RestrictFlowReuse/0base.flows.TerminalOnInfiniteError/0mut .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 -> …,