def completed

bendvy-ecs-core@0.1.0.4 · event_stream.bend:71

import Base

71# Update one reader after execution: success advances to tick; failure preserves
72# unread position while activating absent position under failed-reader rules.
73# Caller supplies actual id/outcome; this does not execute or validate a callback.
74def completed(~S:Data,~E:Data,stream:Stream<S,E>,id:U32,tick:Nat,success:Bool) -> Stream<S,E>:
75  match stream:
76    case Stream{domain,batches,positions,nextReader,frameStart,boundary,capacity,dropped}:Stream{domain,batches,completed_positions(success,positions,id,tick),nextReader,frameStart,boundary,capacity,dropped}