bulk-cdk-core-load/io.airbyte.cdk.load.message/ChannelMessageQueue/poll

poll

open suspend override fun poll(): T?