λ
Это ввод-вывод внутри определения классов модели, оно там не нужно. Не говоря уже о том, что это legacy api, и использовать его вообще не стоит (если это конечно не лаба).
InputStream легаси?
Size: a a a
2020 November 29
В
Fold это про BB-encoding структур данных
А что такое BB-encoding?
G
Это ввод-вывод внутри определения классов модели, оно там не нужно. Не говоря уже о том, что это legacy api, и использовать его вообще не стоит (если это конечно не лаба).
ну а как иначе это сделать, тогда?
AS
ну а как иначе это сделать, тогда?
а что именно нужно сделать?
G
ну, по сути это создание класса из данных с сети
G
можно конечно вынести вообще отдельно туда, где идёт работа с сетью, но в моем случае это не очень удобно
AS
ну, по сути это создание класса из данных с сети
взять что-то неблокирующее для работы с сетью
G
мне не страшно блокирование, у меня все идёт синхронно
AS
можно конечно вынести вообще отдельно туда, где идёт работа с сетью, но в моем случае это не очень удобно
тогда вынести, также можно описать недо-тайпкласс для этого и реализовать его для EntityType
G
не думаю, что это необходимо, но спасибо
VS
см. также Either.fold
Катаморфизм
λ
В
MH
error.seconds
MT
Добрый вечер еще раз, я уже пытался задать этот вопрос, но меня попросили кинуть пример с кодом, что и делаю.
Вот представим что у меня есть задача реализовать сервис
https://scastie.scala-lang.org/yUiZSPz2QhanFYduZtmEig (снипет на 40 строк всего)
Есть пользователи - пользователей можно активировать(опущено) деактивировать и давать им задачи
Деактивированному пользователю задачу давать нельзя
Запрос на деакциваю и на добавление задач приходит из вне абсолютно произвольно и из разных источников
Соответственно возможен кейс что пока пользователь деактивируется ему добавляют задачу
Юзеры лежат не в памяти изначально и всех их в память не вычитать
Вопрос - как бы правильно (фп стайл вот это все) сделать так чтобы для одного и того же пользователя обновления не нахлестывались?
Какие подходы есть? Или почитать где чего?
Вот представим что у меня есть задача реализовать сервис
https://scastie.scala-lang.org/yUiZSPz2QhanFYduZtmEig (снипет на 40 строк всего)
Есть пользователи - пользователей можно активировать(опущено) деактивировать и давать им задачи
Деактивированному пользователю задачу давать нельзя
Запрос на деакциваю и на добавление задач приходит из вне абсолютно произвольно и из разных источников
Соответственно возможен кейс что пока пользователь деактивируется ему добавляют задачу
Юзеры лежат не в памяти изначально и всех их в память не вычитать
Вопрос - как бы правильно (фп стайл вот это все) сделать так чтобы для одного и того же пользователя обновления не нахлестывались?
Какие подходы есть? Или почитать где чего?
λ
вопрос больше по бд, погугли CRDT и CQRS
Oℕ
Добрый вечер еще раз, я уже пытался задать этот вопрос, но меня попросили кинуть пример с кодом, что и делаю.
Вот представим что у меня есть задача реализовать сервис
https://scastie.scala-lang.org/yUiZSPz2QhanFYduZtmEig (снипет на 40 строк всего)
Есть пользователи - пользователей можно активировать(опущено) деактивировать и давать им задачи
Деактивированному пользователю задачу давать нельзя
Запрос на деакциваю и на добавление задач приходит из вне абсолютно произвольно и из разных источников
Соответственно возможен кейс что пока пользователь деактивируется ему добавляют задачу
Юзеры лежат не в памяти изначально и всех их в память не вычитать
Вопрос - как бы правильно (фп стайл вот это все) сделать так чтобы для одного и того же пользователя обновления не нахлестывались?
Какие подходы есть? Или почитать где чего?
Вот представим что у меня есть задача реализовать сервис
https://scastie.scala-lang.org/yUiZSPz2QhanFYduZtmEig (снипет на 40 строк всего)
Есть пользователи - пользователей можно активировать(опущено) деактивировать и давать им задачи
Деактивированному пользователю задачу давать нельзя
Запрос на деакциваю и на добавление задач приходит из вне абсолютно произвольно и из разных источников
Соответственно возможен кейс что пока пользователь деактивируется ему добавляют задачу
Юзеры лежат не в памяти изначально и всех их в память не вычитать
Вопрос - как бы правильно (фп стайл вот это все) сделать так чтобы для одного и того же пользователя обновления не нахлестывались?
Какие подходы есть? Или почитать где чего?
у вас субд с транзакциями есть?
MT
у вас субд с транзакциями есть?
Для этого кейса нет.
Oℕ
если запросы под одному юзеру приходят гарантировано на одну ноду, эту задачу можно реализовать и на STM
MT
если запросы под одному юзеру приходят гарантировано на одну ноду, эту задачу можно реализовать и на STM
На одну.