collect

open suspend override fun collect(collector: FlowCollector<PipelineInputEvent>)(source)