Observable.Range(1, 9999) .Select(i => Observable.FromAsync(() => Task.FromResult(i)))

Question

.Merge(8)
.Subscribe(Console.WriteLine);
- здесь ограничиваем до 8 параллельных операций
как дополнительно ограничить до 5 операций в секунду?

0

04.02.2020

6 просмотров

Dima · Answer 1

есть TokenBucket - https://github.com/esendex/TokenBucket, но может есть решения проще?

0

04.02.2020