MachineStream.batches_into_queue: def of bendvy-ecs-core@0.1.0.4
Import: import bendvy-ecs-core@0.1.0.4/machine_stream.bend as MachineStream
Lines 50-53 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=50&end_line=53

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

def batches_into_queue(~V:Data,batches:List<&2,Ev.Batch<M.Transition<V>>>,queue:Q.Queue<M.Transition<V>>) -> Q.Queue<M.Transition<V>>:
  match batches:
    case []:queue
    case Ev.Batch{tick,+items} <> rest:batches_into_queue(~V,rest,Q.publish_nonempty(~M.Transition<V>,queue,tick,items,Q.count_loop(~M.Transition<V>,items,0n)))

Uses (6):
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=List
  https://jend.leeeet.dev/definition.txt?path=bendvy-ecs-core@0.1.0.4/event_runtime.bend&name=Batch
  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_queue.bend&name=Queue
  https://jend.leeeet.dev/definition.txt?path=bendvy-ecs-core@0.1.0.4/machine_stream_queue.bend&name=count_loop
  https://jend.leeeet.dev/definition.txt?path=bendvy-ecs-core@0.1.0.4/machine_stream_queue.bend&name=publish_nonempty