да

так какая разница? Что сам, что не сам

там кажется используется PatienceConfig глобальный скалатеста

в скалатестах иногда внутрях такая жуть, что лучше не трогать

eventually например

так какая разница? Что сам, что не сам

не хочу спорить. мне готовую собачью еду дают, я ем

futureValue и whenReady отлично работают - никогда не было проблем

там кажется используется PatienceConfig глобальный скалатеста

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

никто не в курсе как сделать partial apply полиморфной функции ?

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

неа, он у меня довольно большой всегда стоит

понятно

а есть встроенная возможность сделать retry теста с большим PatienceConfig?

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

не помню уже почему

кстати, ребзи, что думаете по поводу такого паттерна - есть задача послать сообщение адресату(tcp) и потом когда на него придет ответ, что-то с этим сделать, если при отправке сообщения запихивать в конкаррент мапу пару uuid->completablefuture, и в другом потоке когда будет получен ответ на это сообщение, доставать из мапы футуру, комплитить её, может выполнять какие-то действия...норм?

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

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

можно свой костыль сделать

в смысле все тесты окружать withRetry, и если что-то там по таймауту отвалилось, то делать retry

ну можно и так

у нас для конкретных кейсов такое было, нормально работало

можно в проперти/конфиг переменную с patience прокидывать, и после фейла тестов перезапускать их просто

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

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

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

кстати, ребзи, что думаете по поводу такого паттерна - есть задача послать сообщение адресату(tcp) и потом когда на него придет ответ, что-то с этим сделать, если при отправке сообщения запихивать в конкаррент мапу пару uuid->completablefuture, и в другом потоке когда будет получен ответ на это сообщение, доставать из мапы футуру, комплитить её, может выполнять какие-то действия...норм?

В целом норм, только нагрузочные тесты не забудь, и поиграться с параллелизмом мапы.

Вот как заставить вот это скомпиляться? http://scastie.org/24346

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

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

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

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

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

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

никто не в курсе как сделать partial apply полиморфной функции ?

вот пример, но оно не компилится https://scalafiddle.io/sf/lz08Gmj/0

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

в смысле таймер, timertask на каждую вешать?

Микросервисы в тестах соу сэкси

в смысле таймер, timertask на каждую вешать?

если у тебя тоннами реквесты - нет смысла плодить таймеры. делаешь один инфинит (ну или пока таски есть) шедул и там уже проверяешь очередь

если у тебя тоннами реквесты - нет смысла плодить таймеры. делаешь один инфинит (ну или пока таски есть) шедул и там уже проверяешь очередь

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

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

синкануться только не забудь или на акторах наплоди, чтобы эта просыпашка ничего не попортила)

синкануться только не забудь или на акторах наплоди, чтобы эта просыпашка ничего не попортила)

у меня джава в этом "проектике" :(

если у тебя тоннами реквесты - нет смысла плодить таймеры. делаешь один инфинит (ну или пока таски есть) шедул и там уже проверяешь очередь

1 таймер, да. По которому всё чистить будешь.

синкануться только не забудь или на акторах наплоди, чтобы эта просыпашка ничего не попортила)

конкаррент мапа же

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

конкаррент мапа же

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

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

всё от требований. first-wins тоже норм в определенных случаях

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

каких еще конфликтов? у тебя на один запрос-один ответ и оно определяется у тебя по айди, а не по одинаковости параметров

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

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

каких еще конфликтов? у тебя на один запрос-один ответ и оно определяется у тебя по айди, а не по одинаковости параметров

не, если мне нужно разослать один и тот же запрос многим нодам(например, запрос на чтение данных), и потом по приходу ответов, определить, что отдавать внешней стороне

не, если мне нужно разослать один и тот же запрос многим нодам(например, запрос на чтение данных), и потом по приходу ответов, определить, что отдавать внешней стороне

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

а дальше агрегация обычная

наслаиваешь

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

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

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

и на выход выше отдашь уже общую футурку

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

ребята а в плане бенчмарков расскажите кто быстрее, финч или акка-хттп?

ребята а в плане бенчмарков расскажите кто быстрее, финч или акка-хттп?

У Финча есть ссылки на бенчмарки

держи, если это тебе подходит)

В ридмд

ну или сокращенно val f2 = (f[String] _).andThen(_._1)

вобщем как обычно, нужно немного помощь компилятору)

вот пример, но оно не компилится https://scalafiddle.io/sf/lz08Gmj/0

что-то там не сохранилось, вот тут ворк https://scalafiddle.io/sf/yVn8oVw/0

Так мы тип явно указываем, а я хочу чтобы ф-я была такой же как и f, но возвращала только первый эл-нт из тупла

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

Так мы тип явно указываем, а я хочу чтобы ф-я была такой же как и f, но возвращала только первый эл-нт из тупла

тут шейплес нужен

ща накидаю пример

хотя нет, тут не нужен

def f2[T: test](value:T) = f(value)._1 - можешь еще такую обертку сделать

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

ERROR: S client not available

Засада в том, что у меня много имплиситных параметров, и не хочется плодить boilerplate

вон там Одерски недавно даже пулл реквест запилил специально для неявной прокидки имплиситов - наверное и макросы потом под это дело подтянуться)

да здравствует ад)

имхо, лучше архитектурку пересмотреть в сторону уменьшения имплиситов)

Они нужны для всяких json и футур, в общем имплиситы не мои

вон там Одерски недавно даже пулл реквест запилил специально для неявной прокидки имплиситов - наверное и макросы потом под это дело подтянуться)

макросы (в скаламете) вряд ли это сделают, по крайней мере, в ближайшее время

в скаламете то конечно не сделают и не в ближайшее время) а вот в шейплесах каких-нибудь - пожалуйста)

Лови: http://scastie.org/24353

без шейплеса обошлось

?

@vndzzz

Лови: http://scastie.org/24353

Это уже предложили. Засада в кол-ве тайп классов и имплиситы. Не хочу их дублировать

тут увы, имплиситы из ниоткуда не появятся

всецело поддержу @rudogma , не надо колдунств на имплиситах

Завтра код полный код скину. Посмотрим

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

так наоборт имхо проще. Из-за порядка сразу видны паттерны.

Имея паттерны проще написать новую фичу

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

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

имхо, лучше архитектурку пересмотреть в сторону уменьшения имплиситов)

ты

всецело поддержу @rudogma , не надо колдунств на имплиситах

и ты

оба идёте наXYй

вот из-за мудаков типа тебя, скалистов и считают снобами иди туда сам

=)

я не настоящий скалист, писал на ней всего два проекта

но имплиситы реально сложные в плохом смысле слова

Oleg, я пойду?

Oleg, я пойду?

нет, ты пока останься. Тебя ещё можно обучить тёмной стороне

Я уже в секте Рича

имплиситы вызывают у меня боль