SourcedSubscription

A subscription that reads the published streams of types, aggregates of another context: its filter is of that context, and it handles the records read from each type's topic.