ReservingDeserializingInputFlow
@Singleton
Constructors
Link copied to clipboard
constructor(config: DestinationConfiguration, deserializer: ProtocolMessageDeserializer, @Named(value = "queueMemoryManager") memoryManager: ReservationManager, @Named(value = "inputStream") inputStream: InputStream, @Named(value = "logPerNRecords") logPerNRecords: Long)
Properties
Functions
Link copied to clipboard
open suspend override fun collect(collector: FlowCollector<Pair<Long, Reserved<DestinationMessage>>>)