MachineStream.observe: def of bendvy-ecs-core@0.1.0.4
Import: import bendvy-ecs-core@0.1.0.4/machine_stream.bend as MachineStream
Lines 47-49 of bendvy-ecs-core@0.1.0.4/machine_stream.bend: https://jend.leeeet.dev/read.txt?path=bendvy-ecs-core@0.1.0.4/machine_stream.bend&start_line=47&end_line=49

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

def observe(~V: Data,stream: Stream<V>,+id: U32,tick: Nat) -> Ev.Reading<M.Transition<V>>:
  match stream:
    case Stream{queue,positions,_}: observe_queue_position(~V,Ev.lookup(positions,id),queue,id,tick)

Uses (7):
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Nat
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=U32
  https://jend.leeeet.dev/definition.txt?path=bendvy-ecs-core@0.1.0.4/event_runtime.bend&name=Reading
  https://jend.leeeet.dev/definition.txt?path=bendvy-ecs-core@0.1.0.4/event_runtime.bend&name=lookup
  https://jend.leeeet.dev/definition.txt?path=bendvy-ecs-core@0.1.0.4/machine.bend&name=Transition
  https://jend.leeeet.dev/definition.txt?path=bendvy-ecs-core@0.1.0.4/machine_stream.bend&name=Stream
  https://jend.leeeet.dev/definition.txt?path=bendvy-ecs-core@0.1.0.4/machine_stream.bend&name=observe_queue_position