def observe_registered

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

import Base
import machine.bend as M
import event_runtime.bend as Ev
import machine_stream_queue.bend as Q

40def observe_registered(~V: Data,position: Ev.Position,+queue: Q.Queue<M.Transition<V>>) -> Ev.Reading<M.Transition<V>>:
41  match position queue:
42    case Ev.Position{_,+cursor,registered} Q.Queue{+front,+back,+size,+dropped,+batches}: Ev.Reading{Q.read(~M.Transition<V>,Q.Queue{front,back,size,dropped,batches},cursor),Nat.is_lt(Nat.max(cursor,registered),dropped)}