OwnedEventFamilyReaderQuery.runner_observed: def of bendvy-ecs-core@0.1.0.4
Import: import bendvy-ecs-core@0.1.0.4/owned_event_family_reader_query.bend as OwnedEventFamilyReaderQuery
Lines 77-79 of bendvy-ecs-core@0.1.0.4/owned_event_family_reader_query.bend: https://jend.leeeet.dev/read.txt?path=bendvy-ecs-core@0.1.0.4/owned_event_family_reader_query.bend&start_line=77&end_line=79

import Base
import bendvy-ecs-core@0.1.0.4/change_tick.bend as Tick
import bendvy-ecs-core@0.1.0.4/trace_facts.bend as TraceFacts
import bendvy-ecs-core@0.1.0.4/world.bend as W
import bendvy-ecs-core@0.1.0.4/system.bend as Sys
import bendvy-ecs-core@0.1.0.4/transaction.bend as T
import bendvy-ecs-core@0.1.0.4/compose.bend as Q
import bendvy-ecs-core@0.1.0.4/ordinary_query_declaration.bend as Decl
import bendvy-ecs-core@0.1.0.4/owned_event_log.bend as Log
import bendvy-ecs-core@0.1.0.4/owner_product.bend as Product
import bendvy-ecs-core@0.1.0.4/capabilities.bend as Cap
import bendvy-ecs-core@0.1.0.4/event_runtime.bend as Ev

def runner_observed(~S:Data,~C:Type,~R:Type,~P:Type,~Rest:Type,~E:Data,~path:Product.Lens<R,Log.Log<P>,Rest>,~Request:Type,~Projection:Data,~Args:Type,~Observation:Type,~U:Data,~Out:Data,~Ops:Type -> Type,~at:P -> Request -> P & Projection,~project:@-H:Type -> @-read:Cap.Request<H,Request,Projection> -> H -> Args -> H & Projected<Args,Observation,U>,~query:Decl.Declaration<S,Q.Frame<S,C,R,E>,Ops(Q.Frame<S,C,R,E>)>,~body:@-H:Type -> @-caps:Ops(H) -> Observation -> Args -> H -> H & (Observation & (Args & (T.Outcome<U> & Out))),trace:TraceFacts.State,world:W.World<S,C,R,E>,input:Ev.Input<Nat,Args & Maybe<&2,Tick.Tick>>) -> Sys.Outcome<W.World<S,C,R,E>,Unit,Reply<Args,Observation,U,Out>> & TraceFacts.State:
  match input:
    case Ev.Input{keys,lagged,(args,cursor)}:finish_observed(~S,~C,~R,~E,~Args,~Observation,~U,~Out,lagged,rows(~S,~C,~R,~P,~Rest,~E,~path,~Request,~Projection,~Args,~Observation,~U,~Out,~Ops,~at,~project,~query,~body,keys,cursor,args,T.begin_with_trace(~W.World<S,C,R,E>,~E,world,trace)))

Uses (21):
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Maybe
  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=Sigma
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Unit
  https://jend.leeeet.dev/definition.txt?path=bendvy-ecs-core@0.1.0.4/capabilities.bend&name=Request
  https://jend.leeeet.dev/definition.txt?path=bendvy-ecs-core@0.1.0.4/change_tick.bend&name=Tick
  https://jend.leeeet.dev/definition.txt?path=bendvy-ecs-core@0.1.0.4/compose.bend&name=Frame
  https://jend.leeeet.dev/definition.txt?path=bendvy-ecs-core@0.1.0.4/event_runtime.bend&name=Input
  https://jend.leeeet.dev/definition.txt?path=bendvy-ecs-core@0.1.0.4/ordinary_query_declaration.bend&name=Declaration
  https://jend.leeeet.dev/definition.txt?path=bendvy-ecs-core@0.1.0.4/owned_event_family_reader_query.bend&name=Projected
  https://jend.leeeet.dev/definition.txt?path=bendvy-ecs-core@0.1.0.4/owned_event_family_reader_query.bend&name=Reply
  https://jend.leeeet.dev/definition.txt?path=bendvy-ecs-core@0.1.0.4/owned_event_family_reader_query.bend&name=finish_observed
  https://jend.leeeet.dev/definition.txt?path=bendvy-ecs-core@0.1.0.4/owned_event_family_reader_query.bend&name=rows
  https://jend.leeeet.dev/definition.txt?path=bendvy-ecs-core@0.1.0.4/owned_event_log.bend&name=Log
  https://jend.leeeet.dev/definition.txt?path=bendvy-ecs-core@0.1.0.4/owner_product.bend&name=Lens
  https://jend.leeeet.dev/definition.txt?path=bendvy-ecs-core@0.1.0.4/system.bend&name=Outcome
  https://jend.leeeet.dev/definition.txt?path=bendvy-ecs-core@0.1.0.4/trace_facts.bend&name=State
  https://jend.leeeet.dev/definition.txt?path=bendvy-ecs-core@0.1.0.4/transaction.bend&name=Outcome
  https://jend.leeeet.dev/definition.txt?path=bendvy-ecs-core@0.1.0.4/transaction.bend&name=begin_with_trace
  https://jend.leeeet.dev/definition.txt?path=bendvy-ecs-core@0.1.0.4/world.bend&name=World