bulk-cdk-toolkit-legacy-task-load-dlq/io.airbyte.cdk.load.pipeline.dlq/FlattenQueueAdapter/broadcast

broadcast

open suspend override fun broadcast(value: PipelineEvent<K, DlqStepOutput>)