cats.implicits.catsParallelForEitherTNestedValidated[cats.effect.IO, Unit]( effect.this.IO.ioEffect, cats.implicits.catsKernelStdAlgebraForUnit )

а айзеТ спецом нужен?

cats.implicits.catsParallelForEitherTNestedParallelValidated[cats.effect.IO.Par, cats.effect.IO, Unit]( cats.implicits.catsKernelStdAlgebraForUnit, effect.this.IO.ioParallel(effect.this.IO.timer(scala.concurrent.ExecutionContext.Implicits.global))) );

там же под идее аттемп можно сделать

а айзеТ спецом нужен?

как раз благодаря ему и срабатывает этот эффект молчаливого вывода не того параллела

без трансформера program1 ругнулся бы на отсутствие в скоупе глобал экзекьюшенконтекста

а если внутри шифтить ио?

Саммоню Олега @odomontois

Что. Новому. Хозяину . Нада

Что. Новому. Хозяину . Нада

Сорри за саммон. Лишь мнение. Вывод Parallel похоже стремная штука

Пока не понял, это баг cats-core, cats-effect или scalac

Моникс кстати ведет себя корректно

кек, стрёмно, что он тебе для EitherT вывел не тот параллел?

добавь к аргументам дегуза за BIO

я разобрался как он выводил

могу написать, если интересно кому-то

кроме меня

Я сразу поставил линух и все ок. Есть только одна проблема - есть баг в пульсаудио, из-за которого блютус наушники будут работать в нормальном качестве только у того пользователя, кто первый залогинился. Но это не относится напрямую к ноуту, это проблема оси

Они до сих пор не исправили? Уныние

пиши

Под синтаксическим сахаром .parMapN для тюпла скрывается функция в Parallel: def parMap2[M[_], F[_], A0, A1, Z](m0:M[A0], m1:M[A1])(f: (A0, A1) => Z)(implicit p: NonEmptyParallel[M, F]): M[Z] Эта функция параметризована M и F, и если их явно указать, то конечно все будет работать как надо или не компилироваться вообще. type M[A] = EitherT[IO, Unit, A] type G[A] = Validated[Unit, A] type F[A] = Nested[IO.Par, G, A] val program = Parallel.parMap[M, F, Unit, Unit, Unit](ioA, ioB) { (_, _) => () }Тут я явно указал IO.Par, что весьма дико. Никто естественно указывать тайп-параметры не хочет и положится на автовывод. Компилятору надо найти имплисит p: NonEmptyParallel[M, F], не зная F. Напомню, что мы ищем имплисит для параллелизации EitherT. Лезем в cats.instances.ParallelInstances (который extends ParallelInstances1), там есть вот такой имплисит: implicit def catsParallelForEitherTNestedParallelValidated[F[_], M[_], E: Semigroup] (implicit P: Parallel[M, F]): Parallel[EitherT[M, E, ?], Nested[F, Validated[E, ?], ?]] Он выведется, есть найдется Parallel[M, F] для IO. Что нужно для вывода Parallel для IO: implicit def ioParallel(implicit timer: Timer[IO]): Parallel[IO, IO.Par]И далее: implicit def timer(implicit ec: ExecutionContext): Timer[IO] Так что, если не будет в скоупе ExecutionContext, вся эта цепочка не сработает и будет фолбэк на инстансы для EitherT внутри менее приоритетного ParallelInstances1. Там лежит имплисит послабее, который от внутренней монады не требует инстанса Parallel: implicit def catsParallelForEitherTNestedValidated[M[_]: Monad, E: Semigroup]: Parallel[EitherT[M, E, ?], Nested[M, Validated[E, ?], ?]]

Шерлок прям

Надо было и правда брать бифунктор.

от Луки

Хбокс говно. Только плейстейшон.

там вроде кто то про 18 маг инфы наворовал что 32 гига оперативы 4к моник и другие вкусности

там вроде кто то про 18 маг инфы наворовал что 32 гига оперативы 4к моник и другие вкусности

в понв

Они до сих пор не исправили? Уныние

Ну там ест воркэраунды, но все они довольно костяльные, типа рестарта пульсаудио

А есть у кого книжка Learning Concurrent Programming in Scala? Исключительно для ознакомления

А есть у кого книжка Learning Concurrent Programming in Scala? Исключительно для ознакомления

Allitebooks

Ищем докладчиков на ближайший московский Scala-митап. Писать мне в личку или на aleksey.fomkin@gmail.com. Даты и место проведения уточняются. Не ленитесь, готовьте доклад! Не стесняйтесь агитировать друзей и коллег!

А в ништяках очепятка сама не поправилась ?

что попало в ништяки то там и осталось

блокчеин

Есть два метода def fn[T](x: T): String = ??? def fn[T](x: T*): String = ??? Есть ли способ как-то указать компилятору, что fn(1) относится только к первому методу, а не ловить ошибку?

Есть два метода def fn[T](x: T): String = ??? def fn[T](x: T*): String = ??? Есть ли способ как-то указать компилятору, что fn(1) относится только к первому методу, а не ловить ошибку?

def fn[T](x: T): String = ??? def fn[T](x: T, xs: T*): String = ??? вроде так

благодарю, должно помочь

Скажите пжлста monix.Task.apply запускает вычисление в отдельном потоке, окей а если делать через Effect[Task].delay/pure/point то никак не получается - выполнение запущенных эффектов происходит последовательно

какой метод в Effect эквивалентен executeAsync?

Мне кажется Task.apply ничего не запускает

В мониксе свой scheduler fairness механизм

В котах надо явно ставить асинк баундари

ну вот сейчас я запустил 2 таска через Task{} и сделал Task.gatheUnrodered и они запустились параллельно

а если абстрагироваться из запускать через Effect[Task] то таски выполняются последовательно

Полагаю, чтобы удовлетворить лолкота, нужно заменить "запускает" на "планирует" или "конструирует"

получается сделать только если явно указать Effect[Task].executeAsync но видимо я что-то делаю не так

Полагаю, чтобы удовлетворить лолкота, нужно заменить "запускает" на "планирует" или "конструирует"

да конечно - нужен словарик/переводчик

получается сделать только если явно указать Effect[Task].executeAsync но видимо я что-то делаю не так

А какую ты задачу решаешь? Абстрагируешься от моникса?

получается сделать только если явно указать Effect[Task].executeAsync но видимо я что-то делаю не так

В Effect нет логики "параллельности/конкуретности"

хм

Для этого есть Concurrent

COncurrentEffect?

COncurrentEffect?

Ну это объединение тех двоих, можно его

да смотрю его

Если совсем выхода нет, Можно и через эффект, но грязно через конвертацию в IO и обратно

Но лучше взять ad hoc тайпкласс

а явно написать Effect[Task].point("ololo").executeAsync это коряво?

а явно написать Effect[Task].point("ololo").executeAsync это коряво?

да

Не знаю ни одной задачи, для которой нужно в мониксе саммонить что-то

Кроме какого-то метода в Timer

Не знаю ни одной задачи, для которой нужно в мониксе саммонить что-то

возможно оверинжиниринг, но часть кода захотелось отвязать от конкретного эффекта

чтобы везде не указывать явно Task, а работать через тайпклассы

да спасибо я понял про Concurrent, открыл для себя новый тайпкласс )

В Effect нет логики "параллельности/конкуретности"

а почему тогда Effect экстендит Async?

возможно оверинжиниринг, но часть кода захотелось отвязать от конкретного эффекта

Засаммонив Effect[Task] ты не отвязался от Task

а почему тогда Effect экстендит Async?

Потому что он асинхронный

Асинхронный != конкурентный

всё понял

Засаммонив Effect[Task] ты не отвязался от Task

ну как-же, я с таким же успехом могу и Effect[IO] и еще что-то засунуть

ну как-же, я с таким же успехом могу и Effect[IO] и еще что-то засунуть

Кек. Надо писать эф с дыркой двоеточие тырыпыры

Спроси у Ника

Кек. Надо писать эф с дыркой двоеточие тырыпыры

да так и есть abstract class ExternalProcessor[F[_]](implicit eff: Effect[F]) { и уже не используется Task напрямую

да так и есть abstract class ExternalProcessor[F[_]](implicit eff: Effect[F]) { и уже не используется Task напрямую

Тогда ок

Коль уж пошла такая пьянка, мы также ищем докладчиков на ближайший митап в Санкт-Петербурге, присылайте свои темы в личку мне, @nikitamelnikov или @rockjam

@pomadchin @gurinderu в ништяки плез ^

готово

?

Коль уж пошла такая пьянка, мы также ищем докладчиков на ближайший митап в Санкт-Петербурге, присылайте свои темы в личку мне, @nikitamelnikov или @rockjam

А у вас когда

Точных дат еще нет

https://twitter.com/scala_lang/status/1003639318836105217

Добрый вечер, можно попросить вас о подсказке в Gatling? Есть сценарий следующего вида val someScenario: ScenarioBuilder = scenario("someSimulation") .exec(action0.silent) .exec(action1.silent) .exec(action2.silent) .exec(action3.silent) .exec(action4) .asLongAs(session => session("status").as[String] != "Completed") { exec(action4) pause(5.seconds) } } action4 получает status и сохраняет его значение в сессию При помощи чего можно пробросить это значение внутрь блока asLongAs?

А это значение потом опять используется в action4 внутри блока? Давненько я не видел Гатлинга, но по идее, если это в рамках одного юзера происходит (т.е. считай в рамках одной сессии), то и внутри блока можно все из сессии вытащить, если exec{session=>...} вызвать

подскажите, как правильно делать конверсию scala->java коллекций?

scala.collection.JavaConverters._ дает type mismatch

В данном случае тебе надо примитивы кастить в джава тип

ага.

ты я так понимаю хочешь из джавы колл сделать?

явно укажи в скала коде что хочешь лонг жавовый

не, просто пишу обертку к java-апи

Эс инстанс тут нужен, компайл тайм ошибка, в рантайме лонги одинаковые

Мапнись ._. Не уверен что есть лучше способ

ну можно ж имплиситами =)

подскажите, как правильно делать конверсию scala->java коллекций?

лучше покажи код, который к этому привел. что-то не укладывается в голове метод который принимает скаловую коллекцию, но при этом просит в сигнатуре именно java.lang.Long