def observe_queue_position

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

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

43def observe_queue_position(~V: Data,position: Maybe<Ev.Position>,queue: Q.Queue<M.Transition<V>>,id: U32,tick: Nat) -> Ev.Reading<M.Transition<V>>:
44  match position:
45    case None{}: observe_registered(~V,Ev.Position{id,0n,tick},queue)
46    case Some{position}: observe_registered(~V,position,queue)