Тяжело. На ноуте я ищу в основном в англоязычном интернете. В нем Спутник работает однозначно плохо. На телефоне, где я читаю всякий хлам и периодически гуглю разные термины супетник зашел лучше. В рунете ищет хорошо. Проблема в том, что в айосе все завязано на сафари, а в сафари нельзя выбрать Спутник дефолтным поисковым движком. Спутник-браузер весьма няшный, с брокировкой рекламы, мимими.

гайз, подскажите по akka-streams: как лучше переделать: val consumer: T => Future[Unit] Source[T](…).mapAsyncUnordered(4)(consumer).runWith(Sink.ignore)

я так понимаю, что консьюмера можно запихнуть в Sink

ага, увидел, что foreach так же само запускается

как бы consumer и f разные

да, мне нужен асинхронный вариант прогнать сонсьюмера

asyncForeach такой себе

разница в вызове .map и .mapAsyncUnordered

што за херню ты делаешь)

producer-consumer с backpressure :)

што за херню ты делаешь)

а вообще по-моему практически любая задача, реализованная на akka-streams для стороннего наблюдателя именно так и выглядит

надеюсь они упростят свои API в будущем

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

а вот ты какую-то херню делаешь)

суперкритика

если нужен синк такой. то ни что не мешает его сделать val MySink = Flow[T].mapSync()() to Sink.foreach() все что содержит только вход есть Sink

MySource via TransformFlow to MySink

Подскажите еще, есть ли где-то краткий cheat sheet по akka-streams?

В мануале всё написано, лучше не придумаешь

> В мануале всё написано, лучше не придумаешь

так и есть

Вопрос: в какой джейсон библиотеке есть такая фича case class Foo(@path(«user.id») userId: String, somethingElse: Int) {«user»: { «id»: «123123»}, «somethingElse»: 123123 }

а зачем?

Ну пример говорит сам за себя :)

меньше бойлерплейта?

да но зачем так делать? userId - понятно. а user содержащий непонятно что - не очень )

ну может внешнее апи

ну может внешнее апи

+

вот бы еще с pushka сразу в BSONDocument...

вот бы еще с pushka сразу в BSONDocument...

Создай ишью.

ok :)

ok :)

я серьезно. давно хотел сделать бинарную сереализацию. прикольно когда ищью делаешь не сам, а кто-то еще :)

@fomkin нашёл сериализатор тот что искал?

@fomkin нашёл сериализатор тот что искал?

Пока нет.

как лучше расшарить Source между несколькими потребителями?

я сделал костыль через source.to(Sink.asPublisher(true)).run()

а потом каждый желающий делает Source.fromPublisher(publishеr), но что-то мне подсказывает что это не очень по феншую

может кто знает более элегантное решение?

Пока нет, но в след релизе появится Hub https://github.com/akka/akka/blob/67d0d2a4e33837d8ce22423ef49f9f8365b99286/akka-stream/src/main/scala/akka/stream/scaladsl/Hub.scala#L288

Есть же Broadcast, он не о том?

ну он есть, есть еще и mapAsync

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

вот Hub выглядит весьма вкусно

а потом каждый желающий делает Source.fromPublisher(publishеr), но что-то мне подсказывает что это не очень по феншую

а что будет с backpressure?

а что с ним должно быть?

ну если один из твоих подписчиков динамических затупил

все встанут его ждать?

интересный вопрос

поэтому все не так просто :) в принципе можно сделать fanout, а потом buffer и там уже решить что делать.

но увы это все статитчески

там еще есть другой интересный вопрос - что делать если один из потребителей cancelнул поток или в нем случилась ошибка

стопать ли все?

это уже скорее относится к бизнес-логике

тут вопрос о том что такой кейс возможен и как его реализовать

скорее не как реализовать, а что реализовать. от ответа на этот вопрос зависит как реализовать.

сегодня днюха у Одерски!

Опять пить!

надо пить функциональные напитки

Без сайд эффектов

спирт? у него достаточно много функций

чистый

метиловый

ERROR: S client not available

pure без side effects? функциональщина!

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

ктож как не Британцы

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

наверняка сэр саймон пэйтон-джонс постарался.

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

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

Нет, именно "британские ученые"

видимо это бухло с ЛСД

Кстати в тему http://www.nature.com/nature/journal/vaop/ncurrent/full/nature19112.html

А может быть кто-то встречал описание / реализацию трейсинга на скале. Нужно трейсить время исполнения и какие-то факты во время исполнения (например количество ответов). А потом все это сериализовать и выплюнуть дальше. Не хочется велосипедить.

Есть конечно зипкин, но не из пушки по воробьям же

kamon еще есть

но он тоже жирноват да и аспектами

камон кто-то использовал? он живой / production-ready?

@zuynew использовал

@zuynew расскажи подробнее?

Ну первый момент это aspectj

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

В качестве бекенда юзал statsd

И локально все шикарно

Но на удаленный статсд чет не все доходило

Где терялось точно не могу сказать

ясно. а визуализировал это все как?

Grafana

спасибо

У них есть собранный для акки дешборд

Очень годный

https://github.com/kamon-io/docker-grafana-graphite

С инфлюксом чет не завелась с разу

?

Сейчас юзаем dropwizard

И jmx