bulk-cdk-core-load/io.airbyte.cdk.load.task.internal/DummyStatsMessageConsumer

DummyStatsMessageConsumer

@Singleton
@Requires(property = "airbyte.destination.core.data-channel.medium", value = "SOCKET")
class DummyStatsMessageConsumer(consumer: OutputConsumer) : SuspendFunction1<AirbyteMessage, Unit>

Constructors

Link copied to clipboard
constructor(consumer: OutputConsumer)

Functions

Link copied to clipboard
open suspend operator override fun invoke(message: AirbyteMessage)