PublishedSinks

constructor(published: Map<String, List<PublishedManifest>>, processor: String, sinkOf: (context: String, stream: PublishedManifest) -> Sink)