ReservingDeserializingInputFlow

@Singleton

class ReservingDeserializingInputFlow(val config: DestinationConfiguration, val deserializer: ProtocolMessageDeserializer, @Named(value = "queueMemoryManager") val memoryManager: ReservationManager, @Named(value = "inputStream") val inputStream: InputStream, @Named(value = "logPerNRecords") val logPerNRecords: Long) : Flow<Pair<Long, Reserved<DestinationMessage>>>

Constructors

constructor(config: DestinationConfiguration, deserializer: ProtocolMessageDeserializer, @Named(value = "queueMemoryManager") memoryManager: ReservationManager, @Named(value = "inputStream") inputStream: InputStream, @Named(value = "logPerNRecords") logPerNRecords: Long)

val log: KLogger

open suspend override fun collect(collector: FlowCollector<Pair<Long, Reserved<DestinationMessage>>>)