Предварительная выборка в Flux.concatMap - PullRequest
2 голосов
/ 26 мая 2020

Каково точное использование предварительной выборки в Flux.concatMap? Как и в документации, это «спрос, производимый внутренним источником». Но если мои внутренние источники производят больше, чем значение предварительной выборки, они генерируются concatMap.

1 Ответ

3 голосов
/ 26 мая 2020

Описание параметра в Javado c не самое ясное. Лучшее описание IMHO будет:

Количество элементов, запрошенных от внутреннего источника / издателя для его первого запроса.

Предварительная выборка - это, по сути, оптимизация в реакторе, чтобы попробовать чтобы у нижестоящих операторов всегда было достаточно мощности, чтобы держать их занятыми. Вместо того, чтобы запрашивать элементы один за другим, реактор предварительно запрашивает количество элементов (значение предварительной выборки, по умолчанию 32), а затем запрашивает 75% этого значения, когда 75% израсходованы на постоянной основе.

Это описано в документации реактора по противодавлению , которую стоит прочитать, если вы еще этого не сделали.

...