Constructor InputProcessorImpl
InputProcessorImpl(ConcurrentQueue<TInputRecord>, IKeyConverter<TInputRecord>, ITimeProvider?)
Initializes a new instance, wiring parser events and configuring the input queue.
protected InputProcessorImpl(ConcurrentQueue<TInputRecord> inputBuffer, IKeyConverter<TInputRecord> keyConverter, ITimeProvider? timeProvider = null)
Parameters
inputBufferConcurrentQueue<TInputRecord>Thread-safe queue to be populated with input by IInput<TInputRecord>.
keyConverterIKeyConverter<TInputRecord>Converter for translating
TInputRecordto Key.timeProviderITimeProviderTime provider for timestamps and timing control. Defaults to SystemTimeProvider if null.