Package-level declarations
Types
Link copied to clipboard
class PublishedSinks(published: Map<String, List<PublishedManifest>>, processor: String, sinkOf: (context: String, stream: PublishedManifest) -> Sink)
The built-in sink subscriptions of a node: one SinkSubscription per stream a context publishes (published, by context: the Manifest's published), named <processor>.<aggregate>, each writing to the sink sinkOf gives its stream, with or without the state as the stream says (PublishedManifest.includeState).