def framed_streams

bendvy-ecs-core@0.1.0.4 · event_publication.bend:102

import Base
import world.bend as W
import event_runtime.bend as Ev
import event_stream.bend as Leaf

102def framed_streams(~S:Data,~C:Type,~R:Type,~A:Data,~B:Data,~H:Type,world:W.World<S,C,R,Publication<A,B>>,streams:Streams<S,A,B,H>,tick:Nat,journal:List<&2,Ev.Batch<Publication<A,B>>>) -> Application<S,C,R,A,B,H>:
103  match streams:
104    case Streams{+first,+second,owners}:
105      framed_journal(~S,~C,~R,~A,~B,~H,world,Streams{first,second,owners},tick,retained_journal(~A,~B,journal,Leaf.dropped(~S,~A,first),Leaf.dropped(~S,~B,second)))