Я хотел реализовать что-то вроде протокола двухфазной фиксации для потребления сообщений. Для этого...
У меня есть такая настройка BufferBlock. _inputQueue = new BufferBlock<WorkItem>(new...