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