def append

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

import Base
import bendvy-ecs-core@0.1.0.4/event_runtime.bend as Ev

25# Append nonempty Data publications at the supplied tick using runtime batch rules.
26# Does not advance readers or trim capacity; caller supplies ordered publication data.
27def append(~S:Data,~E:Data,stream:Stream<S,E>,tick:Nat,+values:List<&2,E>) -> Stream<S,E>:
28  match stream:
29    case Stream{domain,+batches,positions,nextReader,frameStart,boundary,capacity,dropped}:Stream{domain,Ev.sync_checked(~E,Nat.is_lt(0n,Ev.count(~E,values)),batches,tick,values),positions,nextReader,frameStart,boundary,capacity,dropped}