AS
Классные, а что в fs2 есть подобное на alsoTo(sink) из акка стримов?
Size: a a a
2020 October 13
Oℕ
Классные, а что в fs2 есть подобное на alsoTo(sink) из акка стримов?
evalTap(doShit(_).start)
AS
evalTap(doShit(_).start)
это примерял, но не то, мне надо в sink слить
Oℕ
синки депрекейтят,
Oℕ
что такое синк
AS
синк это Pipe в Unit
Oℕ
Что делать то в смысле надо
Oℕ
Чем не подошло то
R
синк это Pipe в Unit
.through(sink) ?AS
evalTap аргументом принимает функцию, которая получает элемент из стрима, а мне надо просто сказать - эй, слей заодно данные вот в этот pipe, как в alsoTo в akka-stream
AS
.through(sink) ?это сломает тип на выходе, там будет Unit в получившемся Pipe
Oℕ
Александр, спасибо, что написали много слов, не сообщив дополнительной информации, теперь пожалуйста объясните почему вам нужен именно синк, а не куча независимых дейсвтий
Oℕ
Полный аналог алсо-ту в такой модели стримов - это запихивание в очередь
Oℕ
Но в большинстве случаев можно избежать, оставив флаттап, добавив какой-нибудь там семафор может быть
AS
Александр, спасибо, что написали много слов, не сообщив дополнительной информации, теперь пожалуйста объясните почему вам нужен именно синк, а не куча независимых дейсвтий
ну эээ в кафку сливаю, с akka-stream это был Sink, для fs2 пробую fd4s - предположительно там так же 🤷
Oℕ
Ну сливайте в evalTap
AS
Oℕ
Ну тогда сделайте Queue
В евалтапах забрасывайте в очередь чанки, а из очереди возьмите стрим и скормите еоо этому пайпу
В евалтапах забрасывайте в очередь чанки, а из очереди возьмите стрим и скормите еоо этому пайпу
AS
Ну тогда сделайте Queue
В евалтапах забрасывайте в очередь чанки, а из очереди возьмите стрим и скормите еоо этому пайпу
В евалтапах забрасывайте в очередь чанки, а из очереди возьмите стрим и скормите еоо этому пайпу
как-то страшно, попробую сначала у них в чате спросить ))
AS
ответили - observe