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

оки

я этого бота забанил в руби-чяте превентивно, у меня своя система, если кто-то логинится одновременно в руби-чят и в скала-чят, тот 100% бот, пока не ошибся ни разу

умно

Надо go чат вместо руби

Братюни, чо происходит? Мне сыпется один и тот же мессадж. Когда нажимаю delete and ban всплывает окошко с ошибкой - неавторизованный доступ. Русские хакиры взломали скалачат?

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

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

Там бот падает, если сообщения уже нету, а жмешь delete & ban

Да и delete просто тоже

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

Pattern matching в Scala не использует reflection? Я надеюсь

нет

Гуд, спасибо

Ну есть кейсы где использует конечно

def foo[A: ClassTag](value: Any) = value match { case a: A => ??? case _ => ??? }

Ну если конечно методы Class'а считать рефлексией

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

Учитывая, что в скала слишком легко определить structural type и использовать его где угодно, однозначно ответить "нет" нельзя

https://scastie.scala-lang.org/Odomontois/HVd1YDPrQOihFCz4w6HSwQ/1

https://scastie.scala-lang.org/Odomontois/HVd1YDPrQOihFCz4w6HSwQ/1

a.scala:18: warning: a pattern match on a refinement type is unchecked

def foo[A: ClassTag](value: Any) = value match { case a: A => ??? case _ => ??? }

здесь нет ничего специфичного именно для паттерн мэтчинга

a.scala:18: warning: a pattern match on a refinement type is unchecked

ага

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

Не тащит, с этим я согласен

Но Алексей правильно вспомнил про классстэг. Это хоть и общепринятая но рефлексия

Всем привет! Есть ли аналог Phoenix.Presence в akka?

Всем привет! Есть ли аналог Phoenix.Presence в akka?

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

Получаем, напрмер, список юзеров онлайн, без помощи событий вошёл/вышел

Как бы наблюдатель

Получаем, напрмер, список юзеров онлайн, без помощи событий вошёл/вышел

Rethinkdb

https://github.com/lucastorri/akka-cluster-examples/blob/master/src/main/scala/com/github/lucastorri/akka/demo/cluster/patterns/Presence.scala

не знаю, что там, копирнул из гугла

Есть вопрос на счет akka-streams Кто-нть использовал MergeHub с throttle(…)? Задача - ограничить макс. скорость (tokens / sec) общего выходного потока для динамического набора входных потоков(Producers) Проблема, с которой столкнулся - MergeHub + throttle ограничивает не макс. общего потока, а каждого потока в отдельности ?

ну это и логично, мерж распространяет бэкпрешшур на всех

Ну вроде должен https://doc.akka.io/docs/akka/current/scala/stream/stream-dynamic.html#dynamic-fan-in-and-fan-out-with-mergehub-broadcasthub-and-partitionhub A MergeHub allows to implement a dynamic fan-in junction point in a graph where elements coming from different producers are emitted in a First-Comes-First-Served fashion. If the consumer cannot keep up then all of the producers are backpressured.

ну так и что, как ограничить сумму потоков?

Я хз ? Чот не получется пока ?

думаю, эта задача в приципе не очень решаема

если вопрос в этом

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

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

либо ставить ограничения пропорционально текущему потоку

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

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

Нет под рукой ide проверить, но разве нельзя решить задачу через: Merge ~> buffer ~> throttle ~>

Т.е. из буфера забираем с целевой скоростью

А буффер заполняем со скоростью продьюсеров.

Ну и async там должен быть между.

Ну буфер же только отсрочит проблему

Каким образом?

И собственно, какую проблему?

В общем проблема была в тесте-измерителе скорости ? MergeHub + throttle работает как надо. Сорри ?

Ни у кого не наблюдается проблем со связью с амазоновскими серверами? Конкретно с eu-central-1? Сижу с онлайма, никуда вообще не достукивается, а с йоты всё ок.

eu-central-1 все в норме

сча с гуглом проблемы (

сча с гуглом проблемы (

с GCD или с google.com?

На GCD вот у меня норм заходит всё

И собственно, какую проблему?

Того что буфер рано или поздно заполнится

Того что буфер рано или поздно заполнится

Ну так а бек прешуре на что?

Ну так мерж и остановит все апстримы

Этого как раз и хотели избежать

Задача, вроде как в другом была, но это не стоит отдельной дискуссии.

У Спринга теперь тоже реактивный фреймворк есть. Кто-нибудь успел попробовать?

/toxic

/toxic

что это за словечко постоянно в этом чате вижу, поясните плиз?

твой вопрос тоже /toxic

твой вопрос тоже /toxic

ништяк, а как это понимать?

ништяк, а как это понимать?

Тут все завязано но то, что очень токсичное сообщество у скалы

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

СЛОМАЛ ЧРЕДУ ТОКСИЧНОСТИ

ну что за дела то а

Обещали в бота добавить команду для токсичности

комманда саммонить олега будет

нужно офф стикерпакканала

Обещали в бота добавить команду для токсичности

что она будет делать? избранные цитаты слать?)

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

Олега пикча?

или вот эта рожа^

Она будет показывать в процентах какая сейчас токсичность

Breaking News: Baidu AI beats professional scala developer in toxicity

что она будет делать? избранные цитаты слать?)

брать любой тип и добавлять T[_]

нужно офф стикерпакканала

если у коллеги будет время. то нарисует)

ну сейчас какая-то не токсичная среда

брать любой тип и добавлять T[_]

типы с дырками постить

ну сейчас какая-то не токсичная среда

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

да

типы с дырками постить

?

чтоб Ник батрутдинов набрасывал

@pomadchin а ты мне чтот ответил там?