Oℕ
Size: a a a
Oℕ
Oℕ
S
0.13, кажется. Так что не совсем любой. Подозреваю, что в каком-нибудь допотопном дистре таки можно найти достаточно старый sbt.Oℕ
EB
EB
S
S
Oℕ
S
e

A
e
A
AS
???.evalMap(msg.publish).parEvalMap(maxPublishBufferSize)(identity)
msg.publish на самом деле ничего не паблишит. Он только добавляет сообщение в буфер на паблишинг. Это внешний F. Сделующим шагом я дожидаюсь внутреннего F — он отрабатывает, когда данные из буфера успешно отправлены в кафку. Чтобы не ждать каждого сообщения (то есть не делать буфер размером 1) я делаю parEvalMap(maxPublishBufferSize)(identity), где maxPublishBufferSize — достаточно большое число. В кафка клиенте уже и так есть куча настроек этого буффера, поэтому мне нет смысла (обычно) ещё и на приложении делать какое-то ограничение буфера. Поэтому maxPublishBufferSize я выбираю заведомо больше, чем может влезть в буфер. И получается, что когда буффер отправляется в кафку, сразу пачка этих внутренних F внутри parEvalMap резолвится и идёт дальше по стриму.VG
AV
SS
I