а как ее хандлить если вызываешь больше чем одну фьючу?)

подробнее?

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

finch не позволяет закрывать response в другом месте(не знаю просто) ? есть же кувырок через RequestProxy, в akka-http так можно

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

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

а обычно, что ты понимаешь, видя фейленную фьючу?

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

recover можно на future сделать и мапнуть на что-то типа ErrorFromDb

и в receive ожидать

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

это сообщение набирала собака

recover можно на future сделать и мапнуть на что-то типа ErrorFromDb

ну норм варик, я обычно просто в onCompelte маплю на евенты

а c евентами что делаешь ?

> а что [,] если <,> акка людям не нравит<ь>ся потому[,] что они внутри ак<к>торов futu<e>res готовят ?

> а что [,] если <,> акка людям не нравит<ь>ся потому[,] что они внутри ак<к>торов futu<e>res готовят ?

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

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

Мы вообще компилим на бумажке. СБТ слишком медленный

ну много чего можно сделать - сменить стейт , прибить актор, уйти в таймаут-рейтрай ...

[рожа]

@yourNightCurator готовь каверзные вопросы Олегу на митап

может он с телефона? я вот часто читаю чатик в автобусе

Мы вообще компилим на бумажке. СБТ слишком медленный

у меня батя так биткоины в союзе с друзьями в гараже майнил

finch не позволяет закрывать response в другом месте(не знаю просто) ? есть же кувырок через RequestProxy, в akka-http так можно

val result = Promise[GetResponse] system.actorOf(RequestHandler.props()) ! Get result.map { case error: ErrorResponse => val content = error.asJson.noSpaces error match { case UserTimeOut => case NoObject => case NoUser => } Output.payload(content, Status.NotFound) case rsp: Response => Ok(rsp.asJson.noSpaces) case _ => BadRequest(new RuntimeException("server error")) } class RequestHandler() extends Actor { context.system.scheduler.scheduleOnce(maxRequestDuration) { self ! UserTimeOut } override def receive: Receive = { case Get => context.become(awaitInfo(respone)) } def awaitInfo(response: Promise[GetResponse]): Receive = { case resp: GetResponse => response.setValue(resp) context.stop(self) } }

у меня батя так биткоины в союзе с друзьями в гараже майнил

считал хеши в столбик?

@yourNightCurator готовь каверзные вопросы Олегу на митап

меня в городе не будет =(

получал транзакции заказным письмом?

голубями

меня в городе не будет =(

в каком?

или forall город. меня в городе не будет?

в каком?

filter(_.hasTinkoffOffice)

Seq.empty[City].filter(_.hasTinkoffOffice) :+ City(2)

Seq.empty[City].filter(_.hasTinkoffOffice) :+ City(2)

результат City.apply должен быть Traversable

val result = Promise[GetResponse] system.actorOf(RequestHandler.props()) ! Get result.map { case error: ErrorResponse => val content = error.asJson.noSpaces error match { case UserTimeOut => case NoObject => case NoUser => } Output.payload(content, Status.NotFound) case rsp: Response => Ok(rsp.asJson.noSpaces) case _ => BadRequest(new RuntimeException("server error")) } class RequestHandler() extends Actor { context.system.scheduler.scheduleOnce(maxRequestDuration) { self ! UserTimeOut } override def receive: Receive = { case Get => context.become(awaitInfo(respone)) } def awaitInfo(response: Promise[GetResponse]): Receive = { case resp: GetResponse => response.setValue(resp) context.stop(self) } }

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

или на :+

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

как это каноничней сделать и лучше, я бы хотел услышать (

пушнул фикс

val result = Promise[GetResponse] system.actorOf(RequestHandler.props()) ! Get result.map { case error: ErrorResponse => val content = error.asJson.noSpaces error match { case UserTimeOut => case NoObject => case NoUser => } Output.payload(content, Status.NotFound) case rsp: Response => Ok(rsp.asJson.noSpaces) case _ => BadRequest(new RuntimeException("server error")) } class RequestHandler() extends Actor { context.system.scheduler.scheduleOnce(maxRequestDuration) { self ! UserTimeOut } override def receive: Receive = { case Get => context.become(awaitInfo(respone)) } def awaitInfo(response: Promise[GetResponse]): Receive = { case resp: GetResponse => response.setValue(resp) context.stop(self) } }

как минимум можно убрать лишний become и промис передавать в конструктор актору

val result = Promise[GetResponse] system.actorOf(RequestHandler.props()) ! Get result.map { case error: ErrorResponse => val content = error.asJson.noSpaces error match { case UserTimeOut => case NoObject => case NoUser => } Output.payload(content, Status.NotFound) case rsp: Response => Ok(rsp.asJson.noSpaces) case _ => BadRequest(new RuntimeException("server error")) } class RequestHandler() extends Actor { context.system.scheduler.scheduleOnce(maxRequestDuration) { self ! UserTimeOut } override def receive: Receive = { case Get => context.become(awaitInfo(respone)) } def awaitInfo(response: Promise[GetResponse]): Receive = { case resp: GetResponse => response.setValue(resp) context.stop(self) } }

Под каждый запрос создаеться актор который и рулит ответом но это для akka-http https://pastebin.com/8JWJFu3v

увидел пастебин » не открываю

Под каждый запрос создаеться актор который и рулит ответом но это для akka-http https://pastebin.com/8JWJFu3v

ну тут собственно так и сделано :) просто это к вопросу о финче, с пометкой о том, что лучше ничего не придумал

как это каноничней сделать и лучше, я бы хотел услышать (

https://doc.akka.io/api/akka/current/akka/pattern/FutureRef.html

Пацаны, есть ли легкий способ линеаризовать какие-то вычисления без использования акки? Чтобы, например, так: def linearize[T](action: => Future[T]): Future[T] и гарантировать, что все вызовы linearize будут выполняться строго последовательно, где бы в коде я ни вызвал? Считаем, что этот метод есть в каком-то классе, инстанс которого я шарю между всеми целевыми точками использования.

как это каноничней сделать и лучше, я бы хотел услышать (

а ещё лучше вот так val responseActorRef = MVar.empty[Response] val future = ref.read

Пацаны, есть ли легкий способ линеаризовать какие-то вычисления без использования акки? Чтобы, например, так: def linearize[T](action: => Future[T]): Future[T] и гарантировать, что все вызовы linearize будут выполняться строго последовательно, где бы в коде я ни вызвал? Считаем, что этот метод есть в каком-то классе, инстанс которого я шарю между всеми целевыми точками использования.

тредпул с 1 потоком же

тредпул с 1 потоком же

Ну, я задачу упростил тут, вообще хотелось бы линеаризовать относительно какого-то ключа, тут такой тредпул не зайдёт :)

каждому ключу по тредпулу

Пацаны, есть ли легкий способ линеаризовать какие-то вычисления без использования акки? Чтобы, например, так: def linearize[T](action: => Future[T]): Future[T] и гарантировать, что все вызовы linearize будут выполняться строго последовательно, где бы в коде я ни вызвал? Считаем, что этот метод есть в каком-то классе, инстанс которого я шарю между всеми целевыми точками использования.

def linearize[A](action: => Free[Future, A]): Free[Future, A] = Free.defer(action)

Самое главное, чтобы линеаризовались именно эффекты, а не только результаты

def linearize[A](action: => Free[Future, A]): Free[Future, A] = Free.defer(action)

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

Самое главное, чтобы линеаризовались именно эффекты, а не только результаты

.replace("Future", "Task")

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

какая разница сколько потоков, если действия не вызываются

а складываются во фри

если нужно расшаренное мутабельное состояние, действия с которым нужно линеаризовать

то MVar

for { value <- mvar.take newVal <- actions(value) _ <- mvar.put(newval) }вместо тысячи акторов

А, нет, я не хочу их потом вручную запускать. Это как очередь, в которую с одной стороны сколько угодно человек запихивают, а с другой - один разгребает. Только акторки one-by-one изначально гарантируют

И дают возможность просто плевать сообщения и не думать, кто, как и когда будет разгребать

И дают возможность просто плевать сообщения и не думать, кто, как и когда будет разгребать

Observable

Observable

Да, я туда посмотрел, но я смотрел недолго, и не нашёл ничего такого, что позволило бы мне сделать такой вот api, который я описал, с непрерывно разгребающейся в любой момент очередью. Видимо плохо смотрел

Да, я туда посмотрел, но я смотрел недолго, и не нашёл ничего такого, что позволило бы мне сделать такой вот api, который я описал, с непрерывно разгребающейся в любой момент очередью. Видимо плохо смотрел

не очень понял контракта твоего апи

не очень понял контракта твоего апи

trait Linear { def linearize[T](f: => Future[T]): Future[T] } val l: Linear = ??? в одном месте: l.linearize(Future.successful(1)) в другом l.linearize(Future.successful(2)) Эффекты выполняются линеаризованно, хоть эти места друг от друга вообще не зависят.

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

удобнее ли это будет чем акторы ?

покажи потом что вышло

trait Linear { def linearize[T](f: => Future[T]): Future[T] } val l: Linear = ??? в одном месте: l.linearize(Future.successful(1)) в другом l.linearize(Future.successful(2)) Эффекты выполняются линеаризованно, хоть эти места друг от друга вообще не зависят.

C мониксом можно, но не самое приятное, делать штуку, которая хаотично внезапно может куда-то что-то запихнуть Можно через BufferedObserver, можно через хитрый MVar[Seq] Но самое простое, что я нашёл - это стримы val buttHole = Source .actorRef[() => Future[String]](1000, OverflowStrategy.dropNew) .mapAsync(1)(_ ()) .toMat(Sink.foreach(???))(Keep.left) .run()

ок

пофиксил, теперь buttHole - это ActorRef

C мониксом можно, но не самое приятное, делать штуку, которая хаотично внезапно может куда-то что-то запихнуть Можно через BufferedObserver, можно через хитрый MVar[Seq] Но самое простое, что я нашёл - это стримы val buttHole = Source .actorRef[() => Future[String]](1000, OverflowStrategy.dropNew) .mapAsync(1)(_ ()) .toMat(Sink.foreach(???))(Keep.left) .run()

Да, мне эти варианты приходили в голову, с мваром я пытался наколбасить, но там оказалось слишком хитро. Похоже, что с акторрефом будет самое простое

спасибо

удобнее ли это будет чем акторы ?

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

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

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

а гоняет кто-нить jackson-module-scala вместе с Enumeration магией ?

Да, мне эти варианты приходили в голову, с мваром я пытался наколбасить, но там оказалось слишком хитро. Похоже, что с акторрефом будет самое простое

но я не уверен, что mapAsync не решит вдруг исполнить получитт фьючу, пока ждёт результата предыдущей для уверенности можно на Sink.foldAsync заменить

но я не уверен, что mapAsync не решит вдруг исполнить получитт фьючу, пока ждёт результата предыдущей для уверенности можно на Sink.foldAsync заменить

Да что-то я подумал, что получившийся ActorRef всё равно придется аском спрашивать, или же давать ему какой-то промис, чтобы стрим его комплитил, что еще более геморройно

Да что-то я подумал, что получившийся ActorRef всё равно придется аском спрашивать, или же давать ему какой-то промис, чтобы стрим его комплитил, что еще более геморройно

тебе нужен акноуледж?

тебе нужен акноуледж?

Нужен результат, как в контракте и было

Даю-то я by-name параметр, а получить хочу запущенную футуру с результатом

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

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

Интуитивно не устраивает) Я же спрашивал с целью избавиться от акторов, а пришли всё равно к акторному решению

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

просто это оч все смахивает на кусок шедулера потоков - очередь и разгребатор

Собственно, я почти так выше и описывал про разгребать )

ну и как бы это неприятно не было, это оч похоже на актор

И про очередь сказал:) Просто очень хочется с акторов с аском это на что-то более человечное перевести, не очень мне нравятся эти вот Any, стектрейсы вглубь акки итд

ну тогда свой класс с очередью внутри

или попробуй этих мягких тёплых типизированных акторов

Нужен результат, как в контракте и было

хм ну тогда, наверное,как упоминали, супер-простой выход это mySched = Scheduler(SynchronouaExecution) ... Task.fork(Task.deferFuture(...), mySched))

хм ну тогда, наверное,как упоминали, супер-простой выход это mySched = Scheduler(SynchronouaExecution) ... Task.fork(Task.deferFuture(...), mySched))

Ага, а теперь мне надо линеаризовать относительно ключа, а делать по executor на ключ, сам понимаешь, не вариант. Ну ладно, придётся оставить как есть )

Ага, а теперь мне надо линеаризовать относительно ключа, а делать по executor на ключ, сам понимаешь, не вариант. Ну ладно, придётся оставить как есть )

ну тогда точно MVar val synchonizers = MVar(Map.empty[Map[String, MVar[Unit]]) val result = synchronizer(key) flatMap sync(action) def synchronizer(key: String) = for{ syncs <- synchronizers.take s = syncs.get(key).getOrElse(MVar(())) _ <- synchronizers.put(syncs +(key -> s) } yield sync def sync(action: => Future[A])(s: MVar[Unit]): Task[A] = for{ _ <- s.take res <- Task.deferFuture(action) _ <- s.put(()) } yield res

код с телефона в метро, не обессудь

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

код с телефона в метро, не обессудь

http://phonesdata.com/files/models/Motorola-MILESTONE-900.png такой нужен

У мя был такой