EventPublication.observed_read: def of bendvy-ecs-core@0.1.0.4
Import: import bendvy-ecs-core@0.1.0.4/event_publication.bend as EventPublication
Lines 59-63 of bendvy-ecs-core@0.1.0.4/event_publication.bend: https://jend.leeeet.dev/read.txt?path=bendvy-ecs-core@0.1.0.4/event_publication.bend&start_line=59&end_line=63

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

# Arbitrary finite products can use this same closed selection operation. The
# generated take/put retain every other leaf and arbitrary affine owner H.
def observed_read(~S:Data,~E:Data,~F:Type,~put:F -> Leaf.Stream<S,E> -> F,family:F,returned:Leaf.Stream<S,E> & Ev.Reading<E>) -> F & Ev.Reading<E>:
  match returned:
    case (stream,reading):(put(family,stream),reading)

Uses (4):
  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=bendvy-ecs-core@0.1.0.4/event_runtime.bend&name=Reading
  https://jend.leeeet.dev/definition.txt?path=bendvy-ecs-core@0.1.0.4/event_stream.bend&name=Stream