def event_release_ready

bendvy-ecs-core@0.1.0.4 · ordinary_reader_stream_parameter.bend:235

import bendvy-ecs-core@0.1.0.4/ordinary_reader_stream_parameter.bend as OrdinaryReaderStreamParameter
import Base
import bendvy-ecs-core@0.1.0.4/event_stream.bend as Stream
import bendvy-ecs-core@0.1.0.4/event_family_routing.bend as Route
import bendvy-ecs-core@0.1.0.4/event_notice_runtime.bend as Mixed
import bendvy-ecs-core@0.1.0.4/relation_commands.bend as Notice

235def event_release_ready(~S:Data,~C:Type,~R:Type,~P:Data,~E:Data,~F:Type,~H:Type,
236  ~take:F -> F & Stream.Stream<S,E>,~put:F -> Stream.Stream<S,E> -> F,readerId:U32,
237  context:Route.Runtime<S,C,R,Notice.Notice<S,P>,Mixed.State<S,P,F,H>>) -> Route.Runtime<S,C,R,Notice.Notice<S,P>,Mixed.State<S,P,F,H>>:
238  match context:
239    case Route.Runtime{world,state,+tick}:
240      Route.Runtime{world,event_release_stream(~S,~P,~E,~F,~H,~put,readerId,tick,
241        Mixed.take(~S,~E,~P,~F,~H,~take,state)),tick}

Uses (8)

Used by (1)