def returned

bendvy-ecs-core@0.1.0.3 · execution_relation_failure_channel.bend:13

import Base
import bendvy-ecs-core@0.1.0.3/relation_types.bend as T
import bendvy-ecs-core@0.1.0.3/execution_relation_failure_message.bend as Failure
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

13def returned(~S:Data,~descriptor:T.Descriptor<S>,~origin:Layout.Layout,~route:Layout.Route,reader:Reader<S,descriptor,origin,route>,result:Channel.Store<Failure.Message<S,descriptor>> & Channel.Reading<Failure.Message<S,descriptor>>) -> Channel.Store<Failure.Message<S,descriptor>> & Reading<S,descriptor,origin,route>:
14  match reader result:
15    case reader, (store,Channel.Refused{}):(store,Refused{reader})
16    case Reader{namespace,id,_}, (store,Channel.Read{cursor,messages,missed,tick}):(store,Read{Reader{namespace,id,cursor},messages,missed,tick})