def restored_stream

bendvy-ecs-core@0.1.0.4 · owned_event_family_reader_runtime.bend:40

import Base
import bendvy-ecs-core@0.1.0.4/event_runtime.bend as Ev
import bendvy-ecs-core@0.1.0.4/event_stream.bend as Stream
import bendvy-ecs-core@0.1.0.4/event_family_routing.bend as Route

40# The closed runner retains affine Args even on semantic failure. Route.run must
41# see transport success; reconcile its selected stream to the exact existing
42# failed-reader activation rule afterward, without changing other streams.
43def restored_stream(~S:Data,old:List<&2,Ev.Position>,id:U32,tick:Nat,stream:Stream.Stream<S,Nat>) -> Stream.Stream<S,Nat>:
44  match stream:
45    case Stream.Stream{domain,batches,_,nextReader,frameStart,boundary,capacity,dropped}:Stream.Stream{domain,batches,Ev.activate(old,id,Nat.sub(tick,1n)),nextReader,frameStart,boundary,capacity,dropped}