стримы конечно

eventbus он без backpressure

но проблема в том что оба они локальные

pub/sub ?

если будет несколько инстансов - то кафка то что нужно

*akka publish subscribe я имею ввиду

eventbus он без backpressure

теоретически backpressure на основе AtLeastOnceDelivery в AkkaPersistence не получится реализовать впоследствие для EventBusа?

А что между ними общего?

*akka publish subscribe я имею ввиду

У нас в целом не actor-ориентированная архитектура, т.ч. будет оверхедом скорее всего

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

Зачем rabbit, если есть akka event streams + akka persisnense?

Кролик имеет смысл, если у вас не монолит, и некоторые части не скала/джава

У нас не нужно слать уведомления об ивентах в другие микросервисы

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

необходимость ставить кафку\раббит :)

кстати, народ, кто крутит пенсистенс в проде?

как решаете проблему со сплит-брейнами?

Исходники split brain resolver есть в сети

а легально их использовать можно?

Вдохновиться можно

да документации с головой хватить для вдохновения :)

"...у которых в жизни есть вещи важнее, чем разбираться в системе типов Scala" охлол

конечно, важнные вещи типа дебага stringly typed кода

некогда думать, трясти надо

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

а как в идее обернуть выражение в Some?

есть live template какой-то?

по типу: "foo".sout + Tab => println("foo")

"foo".op + Tab => Option("foo")

ого

надо посмотреть на такие плюшки =)

не работает у меня

может вы сами добавили это?

File->settings->editor->live template->scala можно лицезреть все темплейты (или добавить). Idea eap 2016.2 есть opt - делает паттерн матчинг для Option

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

Номер телефона сменил)

можно же в аккаунте изменить номер

Он заблокирован сейчас. Доступ только из веб приложения есть. А в веб приложении нельзя.

Есть ли легкий способ patter matchить по типу класса? что-то вроде подобного юзкейса def caseClassFactory[T <: SomeTrait](c: Class[T]) = c match

да, classtag нужен

да, classtag нужен

этого ответа я и боялся :)

https://gist.github.com/jkpl/5279ee05cca8cc1ec452fc26ace5b68b

ссылку на саму статью найти не могу, поэтому гист

http://www.cakesolutions.net/teamblogs/ways-to-pattern-match-generic-types-in-scala?utm_campaign=Technical%20Blogs&utm_content=35197950&utm_medium=social&utm_source=linkedin

там вариант с shapeless описан, и с тайп тегами

спасибо, прокурю

этого ответа я и боялся :)

а почему?

пример в пару строк не гуглится, т.е. что-то околоэзотеричное

там нет эзотерики, небольшой чит, который бывает полезен

с класстегами нормально работает. никакой эзотерики :)

http://eax.me/scala-typetags/ - тут коротко и на примере http://docs.scala-lang.org/overviews/reflection/typetags-manifests.html - тут не сильно практично, но с пояснениями

и та статья что выше была - хорошо объясняет, мне кажется

Всем привет. Кто-нибудь при работе с CORS в akka-http использовал https://github.com/lomigmegard/akka-http-cors? Не очень понимаю, почему выходит ошибка "No 'Access-Control-Allow-Origin' header is present on the requested resource" в: val routes: Route = ... post { entity(as[User]) { user => userService.createUser(user) complete(StatusCodes.OK) } } Хотя если просто complete(StatusCodes.OK) без entity(as[User]), то все ок. Кто-нибудь сталкивался с подобным? Спасибо!

кстати почему не handleWith {user: User => userService.createUser(user).mapTo[StatusCode]} Не всегда же создание успешно.

Ответ простой, я еще совсем школоло с akka-http :/

handleWith {user: User => userService.createUser(user).mapTo[StatusCode]} Количество слов user зашкаливает в этой строке)

ехал юзер через юзер

Нормально все.

>>Don't repeat names that are already encapsulated in package or object name Prefer: object User { def get(id: Int): Option[User] }to object User { def getUser(id: Int): Option[User] }They are redundant in use: User.getUser provides no more information than User.get.

ну userService.create() - одно слово только можно убрать

можно повозмущать если можно было бы написать handleWIth(userService.create(_ : User).mapTo[StatusCode]) - но так вроде нельзя

буквоеды :)

user.create(user) ?

(user: UserService).createUser(user: User).mapTo[User]

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

и всё это внутри UserHandler

чтобы больше ада

val userRoutes: Routes = pathPrefix("users")

по идее как-то так было бы красиво userService.createFrom(userHandler).mapTo[StatusCode]

Вообще, там напрашивается u для имени аргумента, при однострочном-то скоупе

Тогда и рябить в глазах перестанет

Привет! Ну теперь могу сказать, что ищем спеца в компанию Эвотор, которую вчера презентовали Греф с Романенко. Что нужно знать и понимать: 1. Функциональные и ООП абстракции и паттерны 2. Особенности разработки и эксплуатации распределенных систем 3. Хотя бы один HTTP фреймворк, akka-http, finagle, play, http4s 4. Akka (sharding, persistence) 5. Как работать с потоками данных (akka-stream, fs2, monix, etc) 6. SQL Плюсом будет: 1. Опыт/понимание CQRS/ES систем 2. Cats/scalaz (Xor, Validation и т.п.) 3. Shapeless 4. Опыт работы с Kafka 5. Опыт работы с Cassandra 6. Опыт работы с Postgres

https://vc.ru/n/sber-qiwi

крутяк

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

где вы раньше были :)

Я писал недели 2 назад ) но никто не заинтересовался

без имен и новостей (нельзя было)

раньше = несколько месяцев назад :)

Насколько хороша практика возвращать и чейнить Future[Unit] (учитывая, что map и flatMap над ними легко спутать), есть какие-то варианты?

используй for comprehension

-Ywarn-value-discard

я для этого писал inspection в скала плагине, только он выключен по-умолчанию

Nested stateful monads This inspection reports nested stateful monads which may lead to architectural errors.

опция компилятора выглядит заманчиво, спасибо

если будет Future[Future[Unit]] или там Try[Option[_]], то идея подсветит. только не все этого хотят

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

жить можно и без, но так спокойней, меньше неявного

а что должна содержать Future, которая ничего не возвращает?

а в чём собственно потенциальная проблема Future[Unit] ?

а что должна содержать Future, которая ничего не возвращает?

она может как минимум быть Failed

я не про то что Future[Unit] плохо

аа

я думал про это

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

не могу придумать случая, когда это Future[Unit] приведёт к проблеме. Может кто-нибудь пример привести?