Господа, я не могу понять одну вещь про акка-стримы. Допустим, у меня в коде есть функция sendToUser(msg: Message) - как сделать, чтобы эта функция была source для akka stream? Или, может, можно как-то сделать стрим, а потом внутри sendToUser(msg: Message) = stream.push(msg) вызывать?

не понял, то есть твою эту функцию иногда кто-то дергает, и она должна пушить в стрим (и небойсь это еще потом должно броадкастить куда-то по вебсокету)?

Я смотрю в сторону чего-то типа BidiFlow.fromFunctions

Господа, я не могу понять одну вещь про акка-стримы. Допустим, у меня в коде есть функция sendToUser(msg: Message) - как сделать, чтобы эта функция была source для akka stream? Или, может, можно как-то сделать стрим, а потом внутри sendToUser(msg: Message) = stream.push(msg) вызывать?

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

не понял, то есть твою эту функцию иногда кто-то дергает, и она должна пушить в стрим (и небойсь это еще потом должно броадкастить куда-то по вебсокету)?

Да

Да

Вот я делал на Source.queue

как Олег выше написал

но я думал, что я херню сделал и можно красивее :(

Я смотрю в сторону чего-то типа BidiFlow.fromFunctions

Олег прав

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

функция шлет msg в акктор который являеться сорсом?

функция шлет msg в акктор который являеться сорсом?

актор не является сорсом

функция шлет msg в акктор который являеться сорсом?

ага. или в актор или в очередь, а очередь мерджить потом

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

У вашей ИДЕ сублаймит

отнесите её к ветеринару

нет, это не ивент сорсинг, спасибо

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

Скажи ты читал доки по акка стримам?

Я в процессе.

Или просто начал хреначить, предполагая, что ты и так всё знаешь про стримы?

Source - это не поток, это не процесс, который течёт

Это Граф

с одним выходом

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

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

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

Source.queue почти то же самое, но только у тебя будет очередь, на другом конце которой будет почти то же самое, что внутри графа

можно руками етот самый актор публишер написать как тебе удобней

если есть нужда

Source.actorRef - таки понял.

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

Ты можешь писать такой у[REDACTED для админов]ский код только если ты разработчик akka-http или StreamRef. Все эти исключения ярчайший показатель отвратительного дизайна сабжа и однажды наконец будут переписаны, я надеюсь

В принципе, да, понял. Но с этим акторрефом у меня тогда следующий вопрос.

Допустим, я на каждого пользователя создаю ActorRef, Stream храню их в мапе. А потом если что-то происходит, там есть какой-то onComplete( => удалить из мапы; отослать PoisonPill актору) ?

Или это тоже не ок дизайн, я заранее как-то при запуске должен создать все эти стримы?

actorRef ! Status.Success("Done")

Допустим, я на каждого пользователя создаю ActorRef, Stream храню их в мапе. А потом если что-то происходит, там есть какой-то onComplete( => удалить из мапы; отослать PoisonPill актору) ?

да PoisonPill в то, что ты материализовал из Source.actorRef приведёт к завершению этого этапа

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

Спасибо, все понял!

actorRef ! Status.Success("Done")

или так да

у меня чет не взлетело

я проверял

))

https://github.com/akka/akka/issues/20421

Говоря про стримы, не стоит быть уверенным, что у тебя не будет утечки

А есть какие-то метрики из коробки, чтобы быть уверенным? Типа как когда создаешь/убиваешь акторы, можно вручную счетчики увеличивать/уменьшать на onCreate onTerminate или как там эти методы называют

можно руками етот самый актор публишер написать как тебе удобней

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

А есть какие-то метрики из коробки, чтобы быть уверенным? Типа как когда создаешь/убиваешь акторы, можно вручную счетчики увеличивать/уменьшать на onCreate onTerminate или как там эти методы называют

нет, это же акка

хочешь быть уверенным - юзай моних

Хочешь быть уверенным - купи DLC

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

хочешь быть уверенным - юзай моних

юзай cats-effect )

https://youtu.be/qaiwalDyayA

хочешь быть уверен отнеси данные в руках на бумажке %(

юзай cats-effect )

вместе с монихом

в эффектах стримов нет

а ФС2 - пулл, всё равно толкатели ручками писать

https://youtu.be/qaiwalDyayA

thx

Monix utterly destroys both fs2 and scalaz-stream on anything that isn't super hilariously heavily chunked, at which point fs2 can edge out an advantage. And by "utterly destroys" I mean "1500x faster". Literally. djspiewak

https://github.com/functional-streams-for-scala/fs2/issues/768

Поэтому пока Румын лично не придёт переделывать фс2, нечего даже смотреть на них

Или лысый....

лысый из бразерс

ERROR: S client not available

нет, это не ивент сорсинг, спасибо

А можно еще раз тот deleted пример?

http://loicdescotte.github.io/posts/play-akka-streams-twitter/

https://github.com/functional-streams-for-scala/fs2/issues/768

вроде за полтора года получше там стало

https://github.com/pheymann/typedapi

бросали

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

ну и пока он безвреден, пока не умеет сваггер

ну и пока он безвреден, пока не умеет сваггер

А зачем всем так нужен сваггер

А зачем всем так нужен сваггер

потому что без сваггера и на чистой akka-http выходит

ну т.е. самая первая цель, которую атакуют все эти typelevel DSL - расширяемая интроспекция.

Т.е. без синтаксиса в типах у тебя выбор приблизительно такой. a) Monoidal, i.e. Applicative-like F[A] х F[B] -> F[A х B] хорошо поддаётся анализу структуры, хорошо выражается параллельность, и легко написать ДСЛ но ты не можешь, например, пользоваться эффектом из A, чтобы вычислить B. Значит автоматически отметаешь все монадически ништяки эффектов б) Monoidal-Categorial, i.e. Arrow-like (A -#> B, B -#> C) -> (A -#> C) (A -#> B, C -#> D) -> ((A х C) -#> (B х D) хорошо поддаётся анализу структуры, и ты можешь чейнить эффекты, контролировать паралллельность и т.п., но ДСЛ написать для такого - просто ппц. даже в хашкеле так себе это всё выглядит в) Monadic, i.e F[F[A]] -> F[A] или (F[A], A -> F[B]) -> F[B] всё отлично чейнится, с помощью прибамбасов, можешь как-то выразить параллельность, но т.к. для того, чтобы получить "продолжение своей структуры" после A тебе нужно засунуть реальное значение в свою функцию, поэтому ты не можешь естественным способом изучить целиком структуру, не запустив На тайплевеле ты можешь описать в какой-то специальной форме весь свой синтакцис, и по желанию скомпилировать в любую из таких форм. Поэтому если тебе не нужно выяснять "а какой параметр будет читать этот метод, после того, как прочитает вот этот, и что он в итоге возвращает" до, собственно запуска своего рута ты можешь удовлетвориться Monadic DSL для akka-http, а основная мотивация выяснить такое в отношении ДСЛ для хттп - выдать схему всех твоих запросов. Например, сваггер

ребят вопрос возможно немного не в ту группу

никто не сталкивался с такой проблемой на айфоне: когда открывается менюшка выбора фотографий останавливается вебсокет

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

и перестает слать какие-либо сообщения

точнее даже вообще вся сеть останавливается

такой отстой

а я так понимаю что у тебя сафари в бекграунд типа уходит?

а понял; да баг какойнить

Небось и правда по тайм-ауту отваливается

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

да походу с этим ничего не сделать

я пробовал обычные http запросы слать тоже самое

на десктопе норм

ну а пока здесь обсуждают айфоны, пойду обсужу скалу в ПОНВ

ребят вопрос возможно немного не в ту группу

Вопрос СОВСЕМ не в ту группу

скаланы, подскажите в чем дело, хочу сделать функтор для псевдонима типа и компилятор говорит что имплисита для Step нет, это нормально? =) type CorrectResponse[T] = Either[Error, T] type Step[T] = Future[CorrectResponse[T]] Functor[Step].map(response)(adults)

если написать вот так то заводится: implicit def stepFunctor = new Functor[Step]{ override def map[A, B](fa: Step[A])(f: A => B) = Functor[Future].compose[CorrectResponse].map(fa)(f) }

импорты лдя инстансов either и future есть