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

consume

open override fun consume(): Flow<T>