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