Можно написать сложный имплисит в стиле древних скалазёвых Unapply

Так работает, да. Но это вообще никак нельзя назвать удобным синтаксисом

Ну такова цена алиасов

можно сделать ща скажу как

яснопонятно

спасибо

Если алиас не подходит, скала будет его распаковывать для анаплай https://scastie.scala-lang.org/Odomontois/2d8sl0NASWarwbsHEtwZ7Q

Не знаю, насколько помогло

А зачем import tofu.syntax.monadic._ ?

да это я пробовал

наш синтаксис ведёт себя почти так же, разве что пишет ,что нет функтора для Bar явно

Хм, подскажите, пожалуйста, а для fs2 — адекватно поведение, когда у меня parJoin может запустить параллельно больше стримов, чем указано в maxOpen?

Я сейчас тестирую со значением maxOpen = 4 , но бывает, что он открывает 5 параллельных стримов

Во "внутренних" стримах у меня только evalMap для тестов, который никогда не должен завершаться (ну и семафор для тесто)

Читай не читай, мне шутка про CORBA язык жгла))

как вы определяете количество стримов запущенных реально?

Во внутренних стримах я тыкаю семафор, а, поскольку они не должны завершаться — я интеррапчу внешний стрим и смотрю, что получилось.

Внутренних стримов у меня, скажем, 10 (semSize), при этом параллельно должно запуститься 4 (parallel), то я смотрю в семафор

это очень странно, потому что в fs2 тоже семафор используется, возможно один из ваших стримов интерраптится, попробуйте вместо acquire withPermit использовать, чтобы он корретктно отмену обработал

возможно, что отмена происходит где-то в конце, когда тест завершается, и пока один из стримов уже отменён, фс2 успевает ещё один запустить

всем привет
подскажите плес, в акка dispatсher-ax есть такой параметр throughput, дословно - макс. кол-во сообщений, после процессинга которых тред переключится на след. актор

вопрос: он переключится, только если у другого актора в очереди есть необработанные сообщения и он будет нуждаться в этом треде, верно?

то есть, если у первого актора на очереди ещё летят сообщения, а у других - нет, то тред не переключится никуда?

нет таких гарантий