pipes

@Singleton

fun pipes(inputFlows: List<DataFlowPipelineInputFlow>, @Named(value = "parse") parse: DataFlowStage, @Named(value = "flush") flush: DataFlowStage, @Named(value = "state") state: DataFlowStage, aggregateStoreFactory: AggregateStoreFactory, stateHistogramStore: StateHistogramStore, statsStore: CommittedStatsStore, aggregatePublishingConfig: AggregatePublishingConfig, @Named(value = "aggregationDispatcher") aggregationDispatcher: CoroutineDispatcher, @Named(value = "flushDispatcher") flushDispatcher: CoroutineDispatcher): List<DataFlowPipeline>