что такое дизраптор?

герой молнии кидает

и запрещает кастить ультой по аое

есть еще менее известный вариант

https://lmax-exchange.github.io/disruptor/

такая себе хай перфоманс очередь

а вот на дотку: https://dota2.ru/heroes/disruptor/

с копьем пушка ваще.

я лично предпочитаю вариант Grigory

бывает и такой вот https://gfycat.com/UnevenFriendlyHectorsdolphin

лол

в тему релокации

что такое аое?

урон по площади, а не по цели

не только урон

Area of effect, aoe damage урон по площади

в тему релокации

Лол

с копьем пушка ваще.

skok mmr

3к помойка

2800 ):

не играю я

охереть вы еще и с хайммр тут лол

не играю я

только в датафестах учавствуешь?

только в датафестах учавствуешь?

в дата фестах 2

чот докерплпгин поменяли, никакие гайды не работают (

кто-нибудь знает хороший мануал по композиции компонентов из akka-stream ?

кроме стандартной доки

кто-нибудь знает хороший мануал по композиции компонентов из akka-stream ?

а там же всё просто

стэковерфлоу

кто-нибудь знает хороший мануал по композиции компонентов из akka-stream ?

мне кажется стандартной достаточно, не?

а знает кто-нибудь, что делать если в проекте на play есть https://github.com/t2v/play2-auth и я хочу все перевести на play2.6?

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

найс идея

акка для чатиков самое оно

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

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

но имхо лучше все перевезти на силуэт

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

но имхо лучше все перевезти на силуэт

а скинь ссылку плиз на него

http://www.silhouette.rocks/

акка для чатиков самое оно

акка-typed, ты имел в виду?

а там же всё просто

Да что-то я не пойму как сделать http source с роутами

http://www.silhouette.rocks/

спасибо)

акка-typed, ты имел в виду?

набрасываешь?

набрасываешь?

выбрасываю актороговно

Да что-то я не пойму как сделать http source с роутами

source чего ты хочешь сделать?

Телеграм мессаджей

Типа мессаги приходят по хттп, энкодятся, передаются в дальнейшие flow, которые в зависимости от логики отдают ответ в sink

Телеграм мессаджей

Конкретней плз, куски кода, минимальный воспроизводимый и т.п.

Бот = труба

выбрасываю актороговно

потому что оно не типобезопасно? но ты используешь эксперементал же

Весь код на акторах пока, я всё начать не могу

Акторы так себе вариант для бота

У тебя сервер слушает апдейты?

или ты забираешь их сам?

Да

Webhook и

ну ок, тогда akka-http все дела

осталось только сериалайзеры найти или написать

Да это все есть

так, а в какой момент нет?

Я не могу понять как делать катомный сурс

Я не могу понять как делать катомный сурс

опиши свои требования с сурсу

как он должен работать

Передеаю в него роуты, на выход он отдаёт мессаги

ERROR: S client not available

так две непонятки 1. Source участвует в стриме, как чистый производитель, на него ничего не передают, передают на Flow и более сложные 2. Route = HttpContext => Future[HttpResult], что должен делать стрим, когда он получит такую функцию?

ща

где шарилка кода

если ты хочешь сурс, на который ты бросаешь объекты, а он их шлёт дальше по стриму - самые простые это Source.actorRef и Source.queue

Первый материализуется в actorRef, на который ты можешь просто ! event

Второй - в тредбезопасную очередь , у которой есть offer

https://scalafiddle.io/sf/Jr8xcvL/0

вот как сейчас я это делаю

передаю на вход параметры и в итоге получаю один сет роутов, которые так и работают с actorRef - ами

ништя я я я я я я я к

но это же и есть source в akka-stream

так я могу два бота / два роута складывать и биндить на один порт

выглядит херова, да)

Oleg бы был бы одним из боссов в какой-нибудь игре типа дарксоулс, но сеттинг про тайплевел программирование

Второй - в тредбезопасную очередь , у которой есть offer

она не тредсейф

она не тредсейф

wait wat

SourceQueue that current source is materialized to is for single thread usage only.

http://doc.akka.io/api/akka/2.4/akka/stream/scaladsl/Source$.html#queue[T](bufferSize:Int,overflowStrategy:akka.stream.OverflowStrategy):akka.stream.scaladsl.Source[T,akka.stream.scaladsl.SourceQueueWithComplete[T]]

is materialized to is for single thread usage only.

даааа

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

он только начал меня уму раззуму учить

Короче. Ты хочешь handler ! callback засунуть в стрим, так?

если я не ошибаюсь то вся серверная часть акки на стримах https://github.com/akka/akka-http/blob/master/akka-http-core/src/main/scala/akka/http/scaladsl/Http.scala#L725

source -> flow -> flow -> flow -> sink source -> это вся часть. которая нужна для приёма http запроса, его переработки и выдачи на выход (в терминалогии акка стримов) готовой структорки, которая далее размазывается по flow

Так

sink это будет http queue

flow это то, что сейчас делается в акторах

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

Или ты хочешь замутить прям свой Flow[HttpRequest, HttpResponse] и засунуть его в bindANdHandle

я хочу фыр фыр фыр

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