bulk-cdk-core-load/io.airbyte.cdk.load.message/StrictPartitionedQueue/broadcast

broadcast

open suspend override fun broadcast(value: T)