λ
В общем я хз что у вас за проблема, я использую зио с дуби и все работает
Size: a a a
2019 December 29
λƒ
В общем я хз что у вас за проблема, я использую зио с дуби и все работает
А что у тебя в E?
λ
Throwable )
λƒ
Throwable )
Ну вот по этому
λ
А, тебе нужен прям тип ошибки
λ
Ну что сказать) тогда жди )
Oℕ
бесплатные готовые инструменты - это туда
Там не так много готовых бесплатных инструментов, как кажется
Oℕ
ну все же не так и страшно fs2 <-> моникс выглядит. моникс ~> fs2 выообще .toStream
покажи плез код интеграции фс2 ⇔актор
GP
покажи плез код интеграции фс2 ⇔актор
я чисто fs2 - monix observable сказал
Oℕ
я чисто fs2 - monix observable сказал
Хорошо, как это сделать
SA
Там не так много готовых бесплатных инструментов, как кажется
мне не кажется, я много лет писал на спринге. При всех своих недостатках, фичи из коробки - это к нему
Oℕ
Но я так-то rx 1. Observable
GP
ну из фс2 в обсервабл как ты и сказал - fromReactivePublisher(stream.toUnicastPublisher())
а из обсервабла в фс2 observable.toReactivePublisher.toStream[IO]
а из обсервабла в фс2 observable.toReactivePublisher.toStream[IO]
GP
ну не так и страшно в целом
Oℕ
ну из фс2 в обсервабл как ты и сказал - fromReactivePublisher(stream.toUnicastPublisher())
а из обсервабла в фс2 observable.toReactivePublisher.toStream[IO]
а из обсервабла в фс2 observable.toReactivePublisher.toStream[IO]
Ты когда-нибудь пробовал потом преобразовывать в пул и обратно такие стримы?
GP
Ты когда-нибудь пробовал потом преобразовывать в пул и обратно такие стримы?
считай нет, я не знаю какие подводные камни у этого
Oℕ
Или там ресурсы вовремя освободить
GP
Или там ресурсы вовремя освободить
расскажи, что там будет?
Oℕ
расскажи, что там будет?
Нужно руками копаться
Oℕ
это значит, нужно посадить разработчика, который там умеет держать в голове конкаренси
не самый дешёвый разработчик как я подозреваю
не самый дешёвый разработчик как я подозреваю