base.flows.ActorImpl[S,E,R]

read #(downstream: mut base.flows._Sink[imm R], state: S, e: E): imm base.flows.ActorRes,
read #(downstream: mut base.flows._Sink[imm R], state: S, e: E): imm base.flows.ActorRes,