Пример C # RX для использования макс. X соединений для наблюдаемого потока - PullRequest
0 голосов
/ 04 июля 2019

Мне нужно что-то похожее на BlockingCollection, чтобы я мог настроить X-соединения (которые будут использовать этот поток IEnum / Obs) и таким образом, чтобы, если какой-либо элемент был завершен, он выбрал следующий элемент.

Я посмотрел пример буфера, который будет ожидать завершения всех элементов X в буфере, прежде чем он сможет перейти к следующему набору.Поскольку некоторые элементы могут занять больше времени, чем другие, чтобы завершитьЯ не хочу ждать 10-го (если X = 10), чтобы закончить перед обработкой следующей партии.Я хочу использовать все X-соединения с максимальной емкостью

...