def event_release_stream

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

import Base
import bendvy-ecs-core@0.1.0.4/event_runtime.bend as Ev
import bendvy-ecs-core@0.1.0.4/event_stream.bend as Stream
import bendvy-ecs-core@0.1.0.4/event_notice_runtime.bend as Mixed

225def event_release_stream(~S:Data,~P:Data,~E:Data,~F:Type,~H:Type,
226  ~put:F -> Stream.Stream<S,E> -> F,id:U32,tick:Nat,
227  selected:Mixed.State<S,P,F,H> & Stream.Stream<S,E>) -> Mixed.State<S,P,F,H>:
228  match selected:
229    case (state,stream):
230      match stream:
231        case Stream.Stream{domain,batches,positions,nextReader,frameStart,boundary,capacity,dropped}:
232          Mixed.put(~S,~E,~P,~F,~H,~put,state,
233            Stream.Stream{domain,batches,Ev.update(positions,id,tick,True{}),nextReader,frameStart,boundary,capacity,dropped})