инсерт не прошел

все, откатилось

Я вот думаю, почему по дефолту незя фолдить булен в скале? Приятнее же чем иф

Щас бы про вкусовщину потереть

Я вот думаю, почему по дефолту незя фолдить булен в скале? Приятнее же чем иф

заверни в опшн

заверни в опшн

эстет

а вы что, думаете что перформанс просядет?

да не, булы вообще рудимент

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

без костра - не тру

Интересно изучить разные варианты. В самообразовательных целях.

https://gist.github.com/Odomontois/f4b9ed4d1bfaf7faa925eed6e567e554 вот сильно упрощённый с Observable при должной сноровке на него можно нацепить любой код с фьючами

@odomontois Спасибо, буду пробовать

Как подружить Spray с LocalDateTime? Error:(48, 44) could not find implicit value for evidence parameter of type JsonSupport.this.JF[java.time.LocalDateTime] implicit val eventFormatter = jsonFormat2(Event) Код Event: case class Event( startTime: LocalDateTime, endTime: LocalDateTime

Код форматтера: trait JsonSupport extends DefaultJsonProtocol with SprayJsonSupport { implicit val eventFormatter = jsonFormat7(Event) }

нужно написать Format для LocalDateTime если его нет

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

нужно написать Format для LocalDateTime если его нет

А как это может примерно выглядеть?

нужно написать Format для LocalDateTime если его нет

Я правильно понимаю, что нужно написать object, экстендящий RootJsonFormat[LocalDateTIme]?

да, скорее всего

А как это может примерно выглядеть?

так чтобы ты мог LocalDateTime превратить в строчку, а потом обратно смог распарсить дату

@odomontois monix - модно-молодежно?

насколько это продакшн реди вопрос

насколько это продакшн реди вопрос

нормально продакшн реди

@odomontois monix - модно-молодежно?

Почти 1 в 1 с rx, вполне-таки годно, только ИМХО, дроч на backpressure с из подходом при Observable.create какой-то, странный, что-ли.

так оно в рамках ConnectionIO транзакционо ж

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

ну ты собираешь огромную фрю

и исполняешь ее транзактором

тип

Делаете ли вы какой-то промежуточный слой абстракции для таких методов или прямо ConnectionIO возвращаете и наслаиваете?

а что там делает транзактор зависит от него самого

но в поставке там все в транзакции

Делаете ли вы какой-то промежуточный слой абстракции для таких методов или прямо ConnectionIO возвращаете и наслаиваете?

каких таких?

каких таких?

Для методов где надо логику отката транзакции группировать, ну например сделал два инсерта друг за другом, если хоть один зафейлился - откатываешь всю транзакцию, после этого сделал еще 3 таким же макаром, но уже например не откатываешь транзакцию, а делаешь что-то другое, это всё - connectionio которые друг на друга наслаиваются или там можно вот так вот как-то группировать и объяснять что вот здесь надо откатить а вот здесь по дефолту?

Для методов где надо логику отката транзакции группировать, ну например сделал два инсерта друг за другом, если хоть один зафейлился - откатываешь всю транзакцию, после этого сделал еще 3 таким же макаром, но уже например не откатываешь транзакцию, а делаешь что-то другое, это всё - connectionio которые друг на друга наслаиваются или там можно вот так вот как-то группировать и объяснять что вот здесь надо откатить а вот здесь по дефолту?

Вроде по докам я вижу, что .transact возвращает IOLite, которое, наверное, композируется, и таким образом можно транзакции так композировать?

возвращает эффект

хочеш IOLite, хочешь Task

и да, эффекты можно композировать

IOLite же вроде из старых версий?

Я не знаю, я открыл ссылку с житхаба, там 0.4 версия

ну 0.4 норм

там две ветки

но бери 0.5

лучше 0.5

там уже cats-effect завезли

Ну короче говоря, эти эффекты, которые представляют собой разные транзакции, я могу скомпоновать, отлично

Почти 1 в 1 с rx, вполне-таки годно, только ИМХО, дроч на backpressure с из подходом при Observable.create какой-то, странный, что-ли.

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

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

А в чем такая большая разница?

господа,не могу в state монаду вкурить.Может у кого были такие проблемы?Есть рекомендации?

господа,не могу в state монаду вкурить.Может у кого были такие проблемы?Есть рекомендации?

начни с формулирования вопросов, что именно не понятно

Ща подумаю

все,догнал.Сорян

чувство будто бы портал в ад открыл

А в чем такая большая разница?

Ленивость, батч-экзекьюшон, куча ништяков, коты

Ленивость, батч-экзекьюшон, куча ништяков, коты

А что под ленивостью подразумеваете?

А что под ленивостью подразумеваете?

Значит, что таск и обсёрвабл - это не штука, которая начинает фигачить свою грязь как только ты её производишь. Это некий чертёж реального эффекта\потока, который запустится, как только его найдёт экзекьютор. Благодаря этому ты получаешь что-то типа referential transparency

можно пояснить, как ленивость даёт referential transparency

Так же как IO монада — конструирование Observable не приводит к сайд эффектам, это просто описание вычисления.

а да, понятно, внутри описанного графа у нас есть RT

вообще, что-то в голове сложилось сейчас, то есть всегда когда мы можем описать граф вычислений, без зависимости от того когда и как эти вычисления будут производиться мы получаем RT

ну если функция выкидывает exception, то она уже не RT, хотя ни от кого не зависит

ну предполагая чистые функции, конечно

слушайте, есть идеи как паттерн Listener, когда кто-то постоянно висит и слушает событие и меняет внутренний var (например pub/sub в редисе или изменение ноды в зукипере) оформить в ФП стиле? пока достаточно уродливый кусок кода выходит в прекрасном мире чистых функций

Похоже на концепцию агентов: https://doc.akka.io/docs/akka/current/agents.html

ERROR: S client not available

Только в Akka они задепрекейчены и не очень “ЭфПэ”.

Agents have been deprecated сразу в лицо )

Но кажется это очень похоже на неблокирующий MVar. Самом недавно о чем-то таком думал, может общественность знает как такая штука может называться?

Хотя если тебе нужно просто получать update по мере доступности, то это MVar и делает.

А мне как раз интересен пример похожий на Agent — асинхронная переменная a la MVar, которая упорядочивает чтения и записи, но не блокирует их.

А мне как раз интересен пример похожий на Agent — асинхронная переменная a la MVar, которая упорядочивает чтения и записи, но не блокирует их.

очередь?)

стрим походу да

т.е. тот же Source.fromQueue или как оно сейчас модно в акке

Я знаком только с акковскими но у них жопаболь с взаимодействием с материализованным стримом.

дык тот же моникс или fs2

т.е. тот же Source.fromQueue или как оно сейчас модно в акке

Ой там столько подводных камней

там нельзя просто фигачить offer

То есть если очень хочется, то поприседать можно, конечно, но в душе свербит ощущение, что должна быть более простая абстракция, может быть в том же monix.

надо респектить протокол

Но пока ничего подобного не видел.

https://oss.sonatype.org/service/local/repositories/releases/archive/co/fs2/fs2-core_2.12/0.10.0-RC1/fs2-core_2.12-0.10.0-RC1-javadoc.jar/!/fs2/async/index.html

С offer’ом норм, очевидно что нужно как-то ограничивать количество команд отправленных в переменную, чтобы не лопнуть по памяти.

на плее делал через такую схема адаптер из актора в sse, оно работало; глубже не лез

С offer’ом норм, очевидно что нужно как-то ограничивать количество команд отправленных в переменную, чтобы не лопнуть по памяти.

Ну тебе надо значит это как-то координировать

но это был старый плей и старая акка

Signal вон: https://oss.sonatype.org/service/local/repositories/releases/archive/co/fs2/fs2-core_2.12/0.10.0-RC1/fs2-core_2.12-0.10.0-RC1-javadoc.jar/!/fs2/async/mutable/Signal.html

там контракт что нельзя делать оффер, пока последний офферн не отработал вроде

Ну тебе надо значит это как-то координировать

Да нет, как раз тут вариант Акки норм — просто фьюча валится и я могу принять решение ретраить или нет.

ок

Signal вон: https://oss.sonatype.org/service/local/repositories/releases/archive/co/fs2/fs2-core_2.12/0.10.0-RC1/fs2-core_2.12-0.10.0-RC1-javadoc.jar/!/fs2/async/mutable/Signal.html

Спасибо, буду посмотреть.

так чтобы ты мог LocalDateTime превратить в строчку, а потом обратно смог распарсить дату

Ок, спасибо!

Ребята не подскажете почему моя маленька фантазия не заработала?

trait Typed[T] { def printType(): Unit ={ print(classOf[T]) } }

Не хочет компелировать

classtag юзай

Да вот что то нарыл, но что то совсем не понятно

что-то такое. надо указать компилятору чтобы он засунул в рантайм инфу о типе abstract class Typed[T: TypeTag] { def printType(): Unit = { print(typeOf[T]) } }