JsonDurableTaskCompletionSourceCommandCodec<T> Methods

JSON codec for durable task completion source journal entries.

Apply(JournalBufferReader, IDurableTaskCompletionSourceCommandHandler<T>)

public void Apply(JournalBufferReader input, IDurableTaskCompletionSourceCommandHandler<T> consumer)

Reads one encoded command and applies it to consumer.

public void WriteCanceled(JournalStreamWriter writer)

Writes a canceled command.

public void WriteCompleted(T value, JournalStreamWriter writer)

Writes a completed command.

public void WriteFaulted(Exception exception, JournalStreamWriter writer)

Writes a faulted command.

public void WritePending(JournalStreamWriter writer)

Writes a pending command.