Скаланы, а как вы проверяете то, что запущенные через fs2-шные

Да, обычно не нужно явно мониторить. Но если реально надо, например, логгировать ситуации типа "уже 20 минут читаем", то в мире zio это можно сделать через комбинацию schedule и race. В кэтс, наверняка, тоже

0

09.03.2021

Tachi Войцишевский Автор вопроса

Evgenii Kuznetcov
Да, обычно не нужно явно мониторить. Но если реаль...

Эт как например?

0

09.03.2021

Evgenii Kuznetcov

Tachi Войцишевский
Эт как например?

Ну я на коленке вот так придумал: def withMonitoring[R, E, A](task: ZIO[R, E, A], tag: String, monitorInterval: Duration = 20.minutes): ZIO[R with Clock, E, A] = { zio.clock.nanoTime.flatMap(start => { val monitorOnce: ZIO[Clock, Nothing, Any] = zio.clock.nanoTime.flatMap(now => UIO { val dur = Duration.fromNanos(now - start) logger.info(s"$tag is running for ${dur.render} so far") } ) val runMonitoring = monitorOnce.delay(monitorInterval).forever task.raceFirst(runMonitoring) }) }

0

09.03.2021

Daniel

если у тебя стримы бесконечные, то мб просто нужен супервайзинг стримов?

0

09.03.2021

Daniel

Tachi Войцишевский
Ну например самое простое — вернуть 5хх и куб рест...

рестартануть весь сервис, если умер 1 стрим? F

0

09.03.2021

Tachi Войцишевский Автор вопроса