bulk-cdk-core-load/io.airbyte.cdk.load.message/MessageWriter/publish

publish

abstract suspend fun publish(message: T)