twirp

Хотел сказать, что еще пара таких тулзов и прагматично скачусь в го, вспомнил про дженерики, погуглил, наткнулся на use copypaste or reflection, передумал

5 стадия смиерния или как там оно называется)

поздравляю ты на первой стадии)

Хотел сказать, что еще пара таких тулзов и прагматично скачусь в го, вспомнил про дженерики, погуглил, наткнулся на use copypaste or reflection, передумал

Обещали запилить жеж

может кукль ещё пару десятков лярдов в маркетинг гошечки вкинет и ты будешь влюблен в этот язык)

Обещали запилить жеж

Одерский вон мне новые коллекции обещает

обещать не значит...

и макросы стабильные (наконец-то будет смысл их учить, текущие-то я не знаю, а уже и не надо, оказывается)

и тайпклассы в языке

и быстрый компилятор

и то что не повторится судьба python 2-3

? все будет ещё жёстче?

уф рустемчик топ. Смотрю он у вас тоже отжигает

уф рустемчик топ. Смотрю он у вас тоже отжигает

пока нет

но мы ждём

он уже ливнул или его ливнули

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

звучит как то что ты попал в такую же проблему, что и ты

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

а зашарь код

а зашарь код

С тасками?

да

Но ведь если твой thunk уже выполняется его невозможно отменить, может по этому?

Но ведь если твой thunk уже выполняется его невозможно отменить, может по этому?

у меня by-name параметр, и я хочу его выполнить только в случае ошибки

да

https://scastie.scala-lang.org/7Pk3REknRVSbzULR0kzkzg

это моних?

ок

да камон

ща придет Олег и будет ругаться за нерабочий скасти

ну или кто-то еще, да :)

бл, нерабочий скасти

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

бл, нерабочий скасти

закрой ладошкой слово перед запятой

):

рибята чот скасти не пашет

пример колла добавь тоже

епт

ща

https://scastie.scala-lang.org/kLX4SROGSli4Ikkxj5R0mw

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

а напомни, у тебя некоторые фьючи виснут в бесконечность, вне зависимости от таймаута?

а напомни, у тебя некоторые фьючи виснут в бесконечность, вне зависимости от таймаута?

да, фьючи нельзя прервать

о, у меня тож такое в тестах происходит, но не на фьючах, а на тасках чисто

хотя не, там runAsync все таки

в jvm чтобы честно прервать фьючу, нужно тред стопнуть

типа того private implicit class WaitTask[T](task: Task[T]) { def taskValue(timeoutOp: Option[Timeout] = None): T = { val future: CancelableFuture[T] = task.runAsync(s) future.onComplete { case Success(_) ⇒ () case Failure(exception) ⇒ exception.printStackTrace() }(s) future.futureValue(timeoutOp.getOrElse(1.second)) } }

у меня правда были подозрение, что где-то IO запускался с runSyncUnsafe, но это не объясняет, почему таймаут не кидается с одной стороны

в jvm чтобы честно прервать фьючу, нужно тред стопнуть

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

у меня таймер в отдельном одном потоке

а не, херню говорю

с тасками да, если сам шедулер заблокирован - то и таймаутов не будет. Но, по идее, шедулер должен уметь это нормально обрабатывать

Скаланы, я вот знаю, что акка стримы любят глотать эксепшоны, но не помню точных обстоятельств. Кто-то может освежить память?

Скаланы, я вот знаю, что акка стримы любят глотать эксепшоны, но не помню точных обстоятельств. Кто-то может освежить память?

Стрим падает от эксепшенов, если ты их не обрабатываешь комбинаторами типа recover

я мб не совсем верно выразился: он не падает, т.е. materialized value я не получаю, он просто по тихому перестает процессить

я мб не совсем верно выразился: он не падает, т.е. materialized value я не получаю, он просто по тихому перестает процессить

Странная хрень

перестает процессить - может просто не просит больше элементов?

я мб не совсем верно выразился: он не падает, т.е. materialized value я не получаю, он просто по тихому перестает процессить

посмотри причину в watchTermination()

перестает процессить - может просто не просит больше элементов?

может и не просит, я только симптом снаружи помню

посмотри причину в watchTermination()

он не терминейтится, в том-то и проблема

хм, т.е. просто зависает?

ага

Ну возможно у тебя mapAsync и где то не завершается фьюча

https://blog.softwaremill.com/akka-streams-pitfalls-to-avoid-part-1-75ef6403c6e6

вот, видимо, если не во фьюче бросить, то можно огрести

ERROR: S client not available

Akka Streams pitfalls to avoid: - Akka Streams usage

да уж

ORLY?? .recover { case e => throw e }

WTF вообще

Короче я победил таймауты: https://scastie.scala-lang.org/2xZFUXpFStiUUxkHga3hpg

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

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

Мне кажется, пора переставать юзать скасти

С таким уровнем стабильности

А зачем ты сделал свой EIther?

хз, можно и either юзать, да

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

Хм, недавно кто-то делал что-то подобное, и там даже 3 разных решения было, но я не помню как)

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

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

Об этом я знаю, и пока мне достаточно и такого.

Об этом я знаю, и пока мне достаточно и такого.

Ну я понимаю, мы обсуждали, просто проговорил в чате, если кто-то наткнётся на решение.

?

Короче я победил таймауты: https://scastie.scala-lang.org/2xZFUXpFStiUUxkHga3hpg

У них в презентации были future с timeout https://www.youtube.com/watch?v=DcJdWYfKcwQ&list=PL-RBtv_a80i5ppRhqtd9MhBZYgdgehvwl&index=28

У них в презентации были future с timeout https://www.youtube.com/watch?v=DcJdWYfKcwQ&list=PL-RBtv_a80i5ppRhqtd9MhBZYgdgehvwl&index=28

У них не такой. У них там просто эксепшен бросается, а мне не это нужно было.

и слайды у них просто вырви глаз. Наклонный текст читать так себе развлечение

У них не такой. У них там просто эксепшен бросается, а мне не это нужно было.

А чем тебе эксепшон плох?

А чем тебе эксепшон плох?

Тем, что у меня там может быть не эксепшен :)

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

в скалаз наверняка чонить типа def withTimeout(t: Duration): IO[Either[E, TimeoutError], A]

а вот и нет https://github.com/scalaz/ioeffect/blob/master/ioeffect/src/main/scala/scalaz/ioeffect/IO.scala#L458

Зачем они сделали другой Option?

Зачем они сделали другой Option?

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

а зачем они это сделали - не знаю точно ¯\_(ツ)_/¯

в скалаз всё своё

Интересно, в хашкеле ещё опшон не выпилили

кек, нет