есть стрим и queue как вход этого стрима. Есть метод который создает стрим, очередь и соединяет их между собой. Наружу возвращается F[Queue[F, Long]]. Мне хочется чтобы частью этого F был запуск стрима через compile.drain. Отсюда два вопроса: как запустить его в фоне и как представить результать это работы в фоне?
В котах есть Deferred который подходит для представления значения, но как запустить что-то как часть сайд эффекта? Вызывать .runAsync(_ => IO.unit).unsafeRunSync() вручную?
for { queue <- createQueque stream = createStream(queue) fiber <- Concurrent[F].start(stream.compile.drain) } yield (queue, fiber)
Обсуждают сегодня