Skip to content

JsonDurableQueueCommandCodec<T>.Apply(JournalBufferReader, IDurableQueueCommandHandler<T>)

Apply(JournalBufferReader, IDurableQueueCommandHandler<T>)

View source
public void Apply(JournalBufferReader input, IDurableQueueCommandHandler<T> consumer)
Reads one encoded command and applies it to consumer.

Parameters

inputJournalBufferReader
consumerIDurableQueueCommandHandler<T>