EventStream.reading: def of bendvy-ecs-core@0.1.0.4
Import: import bendvy-ecs-core@0.1.0.4/event_stream.bend as EventStream
Lines 39-44 of bendvy-ecs-core@0.1.0.4/event_stream.bend: https://jend.leeeet.dev/read.txt?path=bendvy-ecs-core@0.1.0.4/event_stream.bend&start_line=39&end_line=44

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

# Read ordered unread Data plus lag status using an existing position, or a
# not-yet-activated position for id/tick. Returns stream metadata without advancing
# its cursor. This helper does not validate an external reader token or World.
def reading(~S:Data,~E:Data,+stream:Stream<S,E>,+id:U32,+tick:Nat) -> Stream<S,E> & Ev.Reading<E>:
  match stream:
    case Stream{+domain,+batches,+positions,+nextReader,+frameStart,+boundary,+capacity,+dropped}:read_position(~S,~E,Stream{domain,batches,positions,nextReader,frameStart,boundary,capacity,dropped},id,tick,Ev.lookup(positions,id))

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=Pair
  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/event_stream.bend&name=Stream
  https://jend.leeeet.dev/definition.txt?path=bendvy-ecs-core@0.1.0.4/event_stream.bend&name=read_position