def barrier_drained

bendvy-ecs-core@0.1.0.4 · event_notice_runtime.bend:177

import Base
import bendvy-ecs-core@0.1.0.4/relation_commands.bend as Notice
import bendvy-ecs-core@0.1.0.4/internal/relation_failures/barrier.bend as FailureBarrier
import bendvy-ecs-core@0.1.0.4/event_runtime.bend as Ev
import bendvy-ecs-core@0.1.0.4/event_family_runtime.bend as Family
import bendvy-ecs-core@0.1.0.4/event_family_routing.bend as Route

177# The command-aware barrier keeps each command publication as its own batch.
178# Typed owners/journal, reader positions and membership remain unchanged.
179def barrier_drained(~S:Data,~C:Type,~R:Type,~P:Data,~F:Type,~H:Type,typed:Family.State<P,F,H>,positions:List<&2,Ev.Position>,frameStart:Nat,boundary:Nat,capacity:Nat,nextReader:U32,returned:FailureBarrier.BarrierState<S,C,R,Notice.Notice<S,P>>) -> Route.Runtime<S,C,R,Notice.Notice<S,P>,State<S,P,F,H>>:
180  match returned:
181    case FailureBarrier.BarrierState{world,domains,+tick}:Route.Runtime{world,State{typed,Failures{domains,positions,tick,frameStart,boundary,capacity,nextReader}},tick}