169 похожих чатов

Добрый день. Разбираюсь с зивовскими стримами. Сам вопрос: Как в зивовских стримах

задать стартовое значение для стрима, если он создается из ас. функции обратного вызова (ZStream.async)?

Немного контекста

Написал себе простое pub/sub хранилище императивно без фп и пытаюсь его обвернуть в зиву.
Есть три метода:

- getState -> возвращает текущее состояние
- setState -> устанавливает новое состояние
- subscribe -> создает подписку на изменения этого состояния.

2 ответов

27 просмотров

Мб ZStream.succeed(startState) ++ fromAsync ?

Bohdan- Автор вопроса
Никита Мязин
Мб ZStream.succeed(startState) ++ fromAsync ?

Я так и попробовал в лоб, но тут в другом дело. Подозреваю, что я просто плохо понимаю как работают Fiber\Scopes\ZIO в целом. Сейчас заменил runLast на runForEach который в консоль начал логи выводить. Как я понял эффект который возвращается после вызова runLast банально ждет закрытие потока что бы начать выполнять код дальше по компрехеншену. Т.е что это еще не законченное вычисление.

Похожие вопросы

Обсуждают сегодня

Господа, а что сейчас вообще с рынком труда на делфи происходит? Какова ситуация?
Rꙮman Yankꙮvsky
29
А вообще, что может смущать в самой Julia - бы сказал, что нет единого стандартного подхода по многим моментам, поэтому многое выглядит как "хаки" и произвол. Короче говоря, с...
Viktor G.
2
30500 за редактор? )
Владимир
47
а через ESC-код ?
Alexey Kulakov
29
Чёт не понял, я ж правильной функцией воспользовался чтобы вывести отладочную информацию? но что-то она не ловится
notme
18
У меня есть функция где происходит это: write_bit(buffer, 1); write_bit(buffer, 0); write_bit(buffer, 1); write_bit(buffer, 1); write_bit(buffer, 1); w...
~
14
Добрый день! Скажите пожалуйста, а какие программы вы бы рекомендовали написать для того, чтобы научиться управлять памятью? Можно написать динамический массив, можно связный ...
Филипп
7
Недавно Google Project Zero нашёл багу в SQLite с помощью LLM, о чём достаточно было шумно в определённых интернетах, которые сопровождались рассказами, что скоро всех "ибешни...
Alex Sherbakov
5
Ребят в СИ можно реализовать ООП?
Николай
33
https://github.com/erlang/otp/blob/OTP-27.1/lib/kernel/src/logger_h_common.erl#L174 https://github.com/erlang/otp/blob/OTP-27.1/lib/kernel/src/logger_olp.erl#L76 15 лет назад...
Maksim Lapshin
20
Карта сайта