На презенташке про opaque type. > isInstanceOf очевидно не должно быть А как ты его запретишь? это конструкция языка, она должна быть поддержана и работать непротиворечиво.

На презенташке про opaque type. > isInstanceOf очевидно не должно быть А как ты его запретишь? это конструкция языка, она должна быть поддержана и работать непротиворечиво.

ок, я переосмыслил твою реплику

опаки - старая тема, я презенташку даже не видел

ну я про свежую с typelevel summit вроде. Совсем недавно была

А кто сидит на fs2, как с кафкой работаете?

Там ж вроде есть fs2-kafka

оно упоротое какое то и не очень активное

а fs2 в кафку - это конзумер?

там есть выходы, кроме бешенных буферов?

Вообще там Кафка стримы запилили, можно наверное на них навертеть

а fs2 в кафку - это конзумер?

wat?

Вообще там Кафка стримы запилили, можно наверное на них навертеть

ты про кафка стриминг?

wat?

ну я не маг кафки, но имеется в виду заливать в кафку или читать?

ну с заливание особых проблем нет )

я больше про читать

и кафка pull based и fs2 pull based

проблем не вижу

хмммм

наоборот a perfect match

Там ж вроде есть fs2-kafka

Чтобы понять мои опасния стоит знать что это не враппер на джавовым клиентом, они на scodec реализовали протокол.

Насчёт ньютайпов и энивалов - там ещё море вопросов и не факт, что они выйдут в том виде, как показано на презенташке. Основной вопрос - это поведение isInstanceOf и паттерн матчинга

но, в общем, насколько я понимаю доттевское решение проблемы opaque просто не будет наследником Any

поэтому ты не можешь его просто стереть, задаунгрейдить, забыв

Чтобы понять мои опасния стоит знать что это не враппер на джавовым клиентом, они на scodec реализовали протокол.

Общался с чуваками, которые это клиент использовали. Говорили, что он лучше джавового был раньше. Что сейчас - хз

мы говорим про https://github.com/Spinoco/fs2-kafka ?

да

Я к нему приглядываюсь конечно, но пока не готов )

чуваки из dins если что. И вроде кто-то был в этом чате

Чтобы понять мои опасния стоит знать что это не враппер на джавовым клиентом, они на scodec реализовали протокол.

это прямо дерзко.

Ну это потенциально опасно :)

Ну это потенциально опасно :)

это просто опасно.

подскажите, а что сейчас модно использовать для throttlinga в скале? минимум чтобы можно было накрутить свой механизм синхронизации между распределенными узлами. максимум, чтобы это уже было готово.

Ну это потенциально опасно :)

Сомневаюсь , у вас кафку ж тоже не каждый день обновляют

Да и на самом деле протокол не должен меняться )

Скажите есть инстанс MonadError и Effect для Id? В cats

что-то не смог сходу найти

нет

Coeval мониксовый можно взять

Effect нет у Coeval

по понятным причинам

потому что не может быть liftIO, который у Async

Await.result ?

там есть похожее требует что-то типа implicit BlockPermit

not an alley cats, thrash cats

https://www.imdb.com/title/tt4218250/

alien cats

Скажите есть инстанс MonadError и Effect для Id? В cats

но всё-таки

как ты предполагаешь они должны быть реализованы?

как ты предполагаешь они должны быть реализованы?

Сразу throw ex делать

Сразу throw ex делать

да именно так ))) мне для тестов запускать все в Id и не заморачиваться с Await.result

Полагаю, можно реализовать MonadError[Nothing]

да именно так ))) мне для тестов запускать все в Id и не заморачиваться с Await.result

ты не сможешь тогда поймать её

через handleError

хорошо а как тогда в таком случае писать код, чтобы его легко было тестировать? Если я хочу higher kinded type подсунуть в качестве эффекта

для запуска подсовываю Task, а для тестов чтобы не думать про это подсовываю Id например

Или все запускают тесты с Task и это норм?

ну ту часть, которая требует Async

тебе нужен асинхронный эффект

ты же сам его потребовал

Если какой-то кусок требует MonadError, передавай туда Try, Either или Coeval

Юнит-тесты, они ведь юниты тестируют. Не все же единицы твоей программы требуют асинхронного управления?

да конечно не все, какие то куски просто Monad даже

ладно спасибо, обратился к общественному разуму стало понятнее куда идти дальше )

фундаментально экспертизу в дирижировании F[_] я не предоставлю Сам пока не использую FT их основательно, а вот @notxcain использует. Он, наверное, может рассказать, как аккуратно разрезать части логики так, чтобы большая часть из них требовала меньших гарантий

да вот было бы очень интересно

для запуска подсовываю Task, а для тестов чтобы не думать про это подсовываю Id например

Ты подсовываешь то что отвечает твоим требованиям, чаще всего в тестах это State

да конечно не все, какие то куски просто Monad даже

Это самые хорошие куски ))

ERROR: S client not available

А если у него в требованиях Effect в куче мест?

не надо так ?

видимо и тесты запускать в Effect'е сейчас стою на распутье - либо делать сигнатуры с F[_] или забить на это и тесты писать с Await.result

видимо стоит забить на F[_] и гвоздями везде прибить Task в ответах

А если у него в требованиях Effect в куче мест?

Это вообще редко должно встречаться

Это вообще редко должно встречаться

Ну так философская проблема именно в том

Философы ))

Как правильно разархитектурить всё, чтобы имея уже такую проблему

Начать шуршать и двигать сильные требования куда-то в более узкие места

Начать шуршать и двигать сильные требования куда-то в более узкие места

Да, у меня есть место где я мог заинжектить Timer[F], но заинжектил sleepBeforeBlaBla: F[Unit] и тем самым упростил тестирование

Ну это как всегда tradeoff

в примере http4s+doobie не парятся с этим и просто в тестах делают unsafeRunSync https://github.com/jaspervz/todo-http4s-doobie/blob/master/src/test/scala/service/TodoServiceSpec.scala

Ну там особо нет вариантов

потому что репозиторий прибит гвоздями к IO

и потом юзают стабы

не надо так

ужас

да а вот как надо тогда?

если репа возвращает IO, сервис тоже возвращает IO, есть goodpractices как оформить такую простую архитектуру?

Делаешь TodoRepository[F[_]], в тестах делаешь версию где F[A] = State[TestState, A], инжектишь его в сервис, пишешь тест, делаешь val finalState = test.runS(initialState), ассертишь что finalState обладает некими свойствами

/420

/420

но ведь 15:30 :(

Делаешь TodoRepository[F[_]], в тестах делаешь версию где F[A] = State[TestState, A], инжектишь его в сервис, пишешь тест, делаешь val finalState = test.runS(initialState), ассертишь что finalState обладает некими свойствами

ок спасибо, согласен что самый нижний уровень репа и она должна от простых абстракций зависеть уже

конечно, у тебя реальный эффект только на реальны границах IO (не тип)

сеть, файлы, память, время!

а там уже выбирай какой хочешь конкретный тип

хорошо спасибо

обращайся

для запуска подсовываю Task, а для тестов чтобы не думать про это подсовываю Id например

А че не IO

дам там можно подсунуть будет IO.pure { null.asInstanceOf[T] }