эктора. Вопрос - почему как только элемент попадает в эктор, сразу в буфер попадает следующий элемент не дожидаясь Ack из эктора? Это так и должно быть?
Потому что синк из актора без backpressure, если все правильно помню. Раньше помню можно было создать subscriber-а из актора, а из subscriber-а синк, уже с backpessure
Обсуждают сегодня