def returned

bendvy-ecs-core@0.1.0.3 · execution_machine_stream.bend:32

import Base
import bendvy-ecs-core@0.1.0.3/machine.bend as M
import bendvy-ecs-core@0.1.0.3/execution_stream_channel.bend as Channel
import bendvy-ecs-core@0.1.0.3/execution_composer_layout.bend as Layout

32def returned(~S:Data,~K:Data,~V:Data,~origin:Layout.Layout,~route:Layout.Route,reader:Reader<S,K,V,origin,route>,result:Channel.Store<M.Transition<V>> & Channel.Reading<M.Transition<V>>) -> Store<V> & Reading<S,K,V,origin,route>:
33  match reader result:
34    case reader, (store,Channel.Refused{}):(stored(~V,store),Refused{reader})
35    case Reader{namespace,id,_}, (store,Channel.Read{cursor,events,missed,tick}):(stored(~V,store),Read{Reader{namespace,id,cursor},events,missed,tick})