Первый ты можешь реализовать вот с тем же самым кодом через Source.actorRef[Callback]

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

А ты их не будешь определять. Actor будет один как входная точка в твой стрим, он на автомате создастся. Вместо него ты можешь сделать Source.asSubscriber, он то точно должен быть тредсейфовым

Ну или самое крутое - можешь сделать свой stage

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

показывай

я от >> скажи, ты хочешь юзать high level server API опух

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

я от >> скажи, ты хочешь юзать high level server API опух

high level server API - это Route, Directives, то, что у тебя в исходниках

мне главное параметры сохранить bot name, keys, etc и логика чтобы была как я описывал выше

и чтобы я их мог композировать как сейчас val result = Endpoint(1,2,3) + Endpoint(3,4,5); result.bind(8080)

но с последним сам разберусь, если получу пример первого

мне главное параметры сохранить bot name, keys, etc и логика чтобы была как я описывал выше

тогда повторюсь ещё раз, если тебе противен оператор ! сделай Source.asSubscriber

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

что-то мне подсказывает, что зря я сюда полез

ок, Publisher[Callback] выглядит как то, что я искал

ок, Publisher[Callback] выглядит как то, что я искал

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

т.е. не совсем в стиле аккастримов, когда всё, что тебе нужно рождается при материализации

кажется то, что мне нужно это Source.fromGraph(GraphDSL.create() { implicit huyakhuyak} )

вопрос, как в плее задать таймаут на реквест?

гугл не помог(

кажется то, что мне нужно это Source.fromGraph(GraphDSL.create() { implicit huyakhuyak} )

это если ты умеешь хорошо делать Stage

короче надо куда-то это уже выложить, иначе зароюсь в этой акке

@arhelmus не это https://www.playframework.com/documentation/2.5.x/ScalaAsync#Handling-time-outs ?

я правильно понял что по дефолту там нет таймаута?

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

короче надо куда-то это уже выложить, иначе зароюсь в этой акке

нашёл такой кусок кода где-то у себя https://gist.github.com/Odomontois/034d19042b8c26b8d5a241bb5dd8a204

Тинькофф кеш? https://github.com/TinkoffCreditSystems/MacroCache

нашёл такой кусок кода где-то у себя https://gist.github.com/Odomontois/034d19042b8c26b8d5a241bb5dd8a204

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

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

ну вот здесь и нет акторов

О, и правда. затупил.

Но у меня руки кривоваты на конкарренси, мог написать что-то нерабочее

а что хотел написать то?

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

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

вы наверное ищете http://doc.akka.io/japi/akka-stream-and-http-experimental/current/akka/stream/scaladsl/Sink.html#queue()

а, вам в другую сторону.

тоже самое но для сорса

вы наверное ищете http://doc.akka.io/japi/akka-stream-and-http-experimental/current/akka/stream/scaladsl/Sink.html#queue()

Мы его там выше сразу нашли и сразу нам сказали, что он thread-unsafe

http://doc.akka.io/japi/akka-stream-and-http-experimental/current/akka/stream/scaladsl/Source.html#queue(int, akka.stream.OverflowStrategy, scala.concurrent.duration.FiniteDuration)

Я не понял что это и зачем это

http://doc.akka.io/japi/akka-stream-and-http-experimental/current/akka/stream/scaladsl/Source.html#queue(int, akka.stream.OverflowStrategy, scala.concurrent.duration.FiniteDuration)

Соответственно, thread unsafe Неприменим, а actorRef - обмазываться в акторах

печально что оно в один поток только умеет :(

А ты как-то намеренно javadoc вместо скаладока кидаешь?

я просто загуглил. меня отправило туда

Еще двое и нас 700

Еще 1302 и нас легион

(@kotlin_lang чат все равно уже не догнать)

/stat@combot

combot.org/chat/-1001034178083

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

что людей больше, а активности меньше

Кол-во сообщений не показатель (хотя меньше флуда - больше по делу). Зато там распределение “активности” в первой 10-ке лучше, а здесь ты один почти 11% нафлудил.

Кол-во сообщений не показатель (хотя меньше флуда - больше по делу). Зато там распределение “активности” в первой 10-ке лучше, а здесь ты один почти 11% нафлудил.

но там же сплошной флуд

Послушал наконец последний подкаст и он разрушил мой мирок. Я все думал - сейчас dotty придет и убьет макросы, а на замену будет мета и все станет хорошо (и красный код в IDEA исчезнет ?). А тут оказывается что мета и не для макросов, а для анализаторов кода что-ли???. И за два часа подкаста так и не объяснили, как макросы будут реализованы в dotty. Что там в итоге с макросами?

макросы в отдельной репе теперь: https://github.com/scalamacros/scalamacros/pull/1 и все будет в дотти (ну пока все будет)

скала мета это скала мета а скала макрос это скала макрос ._. (такое pr разделение)

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

макросы в отдельной репе теперь: https://github.com/scalamacros/scalamacros/pull/1 и все будет в дотти (ну пока все будет)

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

да вроде скала мета уже хорошо идеей поддерживается

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

собсно больше всего интересует последний пункт — будет ли эквивалентное апи большинству операций из скаларефлекта для dotty/scalamacros

каждая первая крупная либа под капотом (или в зависимостях) юзает scalareflect макросы

ERROR: S client not available

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

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

в теории семантик дб очень сильно может с этим помочь

ну, будем надеяться

@gurinderu как в докере нормально сеть настроить?

что значит нормально

Чтобы ты доволен был

не бывает такого

Ну общие рекомендации есть, если amqp активно используются внешние?

бриджом делай, чтоб порты не пересекались)

object LoggingTryInterpreter extends (Try ~> Id) { def apply[A](fa: Try[A]): Id[A] = fa.fold(???, x => {???; x}) }

блин, я наверное плохо описал что хочу. просто логирующую обертку яснопонятно можно написать, мне же хотелось, чтобы во всех случаях были сообщения кастомные соответствующие ситуации, выполнил f1, залогировал ok или error с конкретным сообщением, если ok, пошел делать f2, и так далее, и сообщения для f1 и f2 будут различаться как для ok, так и для error. validated же вроде выполнит всё и не остановится на первой ошибке?

бриджом делай, чтоб порты не пересекались)

cпасибо большое!

за что

за что

за совет

Скаланы, не в тему вопрос. Ни у кого не завалялось руководителя эксплуатации? :) Может кому из ваших знакомых интересна позиция?

а что это за зверь такой?)

завхоз наверное

http://cdn2.hubspot.net/hub/228391/file-745508197-jpg/blog-files/devopsevil.jpg

вот это руководитель тех самых OPS :)

серверы, сети и прочие радости

Послушал наконец последний подкаст и он разрушил мой мирок. Я все думал - сейчас dotty придет и убьет макросы, а на замену будет мета и все станет хорошо (и красный код в IDEA исчезнет ?). А тут оказывается что мета и не для макросов, а для анализаторов кода что-ли???. И за два часа подкаста так и не объяснили, как макросы будут реализованы в dotty. Что там в итоге с макросами?

Там ещё есть развёрнутый комментарий про различия, от Евгения Б. на странице http://scalalaz.ru/series-23.html

Ты мне напомнил про второй вопрос, который возник после подкаста. Зачем перед _каждым_ ответом говорить “спасибо за хорошие вопросы” (это обесценивает действительно хорошие вопросы ?). Это какие-то Европейско-Лозаннские-(толерантные)-ценности?

Ты мне напомнил про второй вопрос, который возник после подкаста. Зачем перед _каждым_ ответом говорить “спасибо за хорошие вопросы” (это обесценивает действительно хорошие вопросы ?). Это какие-то Европейско-Лозаннские-(толерантные)-ценности?

это все твоя токсичность

ваще

это все твоя токсичность

OK, спасибо за хороший комментарий

@pomadchin ты грубый, я думаю тебе тоже стоит поблагодарить @angmarr в ответ

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

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

Посоны, @fomkin , петрашку или бурмако сложно привезти в Россию?

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