если в их собственных сеттингах не оверрайдятся

отлично, значит всё правильно понял. спасибо!

есть ли для GetResult в plain sql slick какие-то свистелки помогающие убрать боилерплейт?

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

в скала коллекциях вообще есть такие методы?

или надо мутиться через .split

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

а TreeMap по дефолту отсортирована по ключу

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

https://www.scala-lang.org/api/current/scala/collection/mutable/LinkedList.html insert

мутабл лист, такое себе)

private var state = new TreeMap[String, ActorRef]()(implicitly[Ordering[String]].reverse) забавный велосипед вышел

ПОчти такое же хотел предложить https://scastie.scala-lang.org/Odomontois/hpPGxPmtSLuDLYVqozLgiw

я плохо понял зачем тегать последнюю цифру в числе

kak je gorit ot scala 2.10.6

фетиш на постарше?)

spark 1.3 под 2.10

кривда любитель милфоспарка

поэтому я не занимаюсь бигдатой

ну контейнеры спасли бы меня, но не спасут)

вынес в другой модуль и всё заработало

а не, оно просто позже стало падать) ленивая иницилизация наше всё

а чо у тя там падает

Кто-нибудь gradle пользуется? В последней версии scala-плагина (2017.2.7) для идеи, перестало работать добавление compiler plugin-а и нескольких параметров для него через scalaCompileOptions.additionalParameters, bad option пишет

Переписал я значит всё с Scala на build.sbt, по документации и гайдами, вот это всё. Переписал, и пытаюсь загрузить в сбт, а там NullPointerException. https://gist.github.com/folex/41bdd9dc1312e767cb239816adb98d5f what do I do now? :(

как это отлаживать?

дописать в JAVA_OPTS дебаг

а какой sbt?

аааа во, у тебя прожекты ведь лейзи валами?

lazy val core = project ...

я плохо понял зачем тегать последнюю цифру в числе

последняя цифра - это название тега, а не то, что он тегает) тегает он ключ, чтобы тримап с ключем ластдигит был, а не просто инт и свой имплисит ордеринг подтянул к ластдигиту относящийся, а не к инту, при этом поскольку это тег - он не прячет основание и все операции которые с интом можно делать, можно и с тегированным делать x % 10 . рисуется вобщем, чтобы пример не скуфный был)

lazy val core = project ...

ага, точно! Щас попробую. Мне сбт прост как-то запретил делать lazy val project = { import ... project.in(...) } , и я чот решил что это от lazy, удалил, и забыл

да, это оно. Спасибо!

а кто знает, если я создам два персистенс актора с одинаковым id, акка поймет это и убьет один из них?

в пределах одной актор систем

c persistence id?

думаю нет. скорее всего они просто начнут портить журнал

В build.sbt есть какие-то новые правила по поводу ivyScala := ivyScala.value map { _.copy(overrideScalaVersion = true) }, ? Я добавил это в inThisBuild, и у меня выдает что в одном из подпроектов: [error] Reference to undefined setting: [error] [error] {.}/*:ivyScala from {.}/*:ivyScala (/Development/server/project/Settings.scala:55) [error] Did you mean submoduleNameHere/*:ivyScala ? [error]

если закомментировать это — проходит. Где-то синтаксическая ошибка? или не везде есть ivyScala ключ? Вроде в sbt.Keys лежит

если закомментировать это — проходит. Где-то синтаксическая ошибка? или не везде есть ivyScala ключ? Вроде в sbt.Keys лежит

в 1.х нету, может тебе ivySbt нужен?

А у меня 0.13.16

на 1.х не вышло перейти из-за плагинов :(

sbt-play, sbt-scrooge

может через пару месяцев получится

0.13.16 переходная версия, подозреваю там какие-то моменты уже могут быть как в 1.х

До этого работало, после миграции на .sbt сломалось. Может быть и правда что-то такое.

Кто-то пили сериализацию дженериков для акка кластера? Пока вышло с kryo idstrategy="default", но я бы хотел налепить на протобафе что-то case class Envelope[T](value: T) учитывая, что я знаю, как T преобразовать в bytearray

...как начнешь скалу с аккой склеивать, так таким дерьмом тянуть начинает

можешь просто сделать трейт-маркер для всего сериализуемого

и в сериализаторе матчить этот трейт

Кто-то пили сериализацию дженериков для акка кластера? Пока вышло с kryo idstrategy="default", но я бы хотел налепить на протобафе что-то case class Envelope[T](value: T) учитывая, что я знаю, как T преобразовать в bytearray

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

и в сериализаторе матчить этот трейт

я хочу волшебства: сделать использовать для сериализации самого Т некий тайпкласс, а сериализатор Envelope бы каким-то образом брал уже сериализованный Т и упаковывал себя вместе с ним т.ч. в конфиге я бы определил только сериализатор для Envelope, а остальное на уровне типов

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

волшебства не бывает к сожалению

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

используй чилл)

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

я хочу волшебства: сделать использовать для сериализации самого Т некий тайпкласс, а сериализатор Envelope бы каким-то образом брал уже сериализованный Т и упаковывал себя вместе с ним т.ч. в конфиге я бы определил только сериализатор для Envelope, а остальное на уровне типов

ну всё просто, имплементишь http://doc.akka.io/api/akka/current/akka/serialization/Serializer.html объявляешь свой тайпкласс как implicit val, засовываешь в него всяческие тайптеги, добавляешь какую-нибудь хрень типа процесса инициализации с регистрацией в гигантской мапе по тайптегу оригинального сериалайзер и тех, от которых он зависит, собираешь все инициализации при старте приложения, получаешь кучу багов, тормозов, те же проблемы, что с крио, но без крио

что-нибудь при этом еще можно сделать на макросах и все равно будет грустно(

думаю, мечтать о тайпклассах можно перестать уже когда видишь def toBinary(o: AnyRef): Array[Byte] и начинаешь сочинять как искать свой тайпкласс в AnyRef

но полагаю с тайптегами и поиском val в рефлекшоне, соответствующему сохранённому инстансу можно навернуть что-то

через раз работающее

ну или просто замутить trait MySerializable[ T <: MySerializable] { implicit def serialize: Serialize[T] }а в своих кейз классах case class Envelope[T](val x: T)(implicit val serialize: Serialize[Envelope[T]]) extends MySerializable[Envelope[T]]

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

макросами добавлять нельзя?

конфиг генерить можно же наверняка?

конфиг генерить можно же наверняка?

думаю, в лучшем случае плагинами sbt без явного перечисления типов где-то

Привет всем, вот захотелось мне ленивую генерилку всего и вся сделать. Помимо прочего нагуглилось вот это https://stackoverflow.com/questions/3797699/generator-block-to-iterator-stream-conversion В общем, топовый ответ оттуда: scala> def data(f : Int => Unit) = for(i <- 1 to 10) { | println("Generating " + i) | f(i) | } data: (f: (Int) => Unit)Unit scala> def toTraversable[T]( func : (T => Unit) => Unit) = new Traversable[T] { | def foreach[X]( f : T => X) = func(f(_) : Unit) | } toTraversable: [T](func: ((T) => Unit) => Unit)java.lang.Object with Traversable[T] Использование: scala> toTraversable(data).view.take(3).sum Generating 1 Generating 2 Generating 3 Generating 4 res1: Int = 6 Если в дебагере смотреть, Traversable генерируется до конца (так полагаю watcher'ы высчитываются и побуждают эту генерацию), но потом все таки выполняется take(3), но не как я бы ожидала. Там магия какая-то: внутри data, после выполнения f(i) мы перескакиваем обратно на foreach в traversable, а как бы цикл for(i <- 1 to 10), который внутри data, игнорируем. Я увидела breaks в traversable trait'е, но не осилила где они используются и как это работает. Anyone knows?

есть отличная статься на тему ленивости и стримов http://derekwyatt.org/2011/07/29/understanding-scala-streams-through-fibonacci/

есть отличная статься на тему ленивости и стримов http://derekwyatt.org/2011/07/29/understanding-scala-streams-through-fibonacci/

Мне она тоже понравилась, но она не объясняет предыдущий пример. Или я упустила что-то? :(

В итоге, я в проде и пишу first #:: blahblah, просто любопытно как TraversableView это делает.

В итоге, я в проде и пишу first #:: blahblah, просто любопытно как TraversableView это делает.

насколько я помню магию примесей для своих коллекций, которые работают на одном только foreach, take и head запускают в foreach код, который бросает эксепшн когда айтемов больше не нужно, который выше ловится

насколько я помню магию примесей для своих коллекций, которые работают на одном только foreach, take и head запускают в foreach код, который бросает эксепшн когда айтемов больше не нужно, который выше ловится

так и есть

f - которая в дату пихается его и бросает

Привет всем, вот захотелось мне ленивую генерилку всего и вся сделать. Помимо прочего нагуглилось вот это https://stackoverflow.com/questions/3797699/generator-block-to-iterator-stream-conversion В общем, топовый ответ оттуда: scala> def data(f : Int => Unit) = for(i <- 1 to 10) { | println("Generating " + i) | f(i) | } data: (f: (Int) => Unit)Unit scala> def toTraversable[T]( func : (T => Unit) => Unit) = new Traversable[T] { | def foreach[X]( f : T => X) = func(f(_) : Unit) | } toTraversable: [T](func: ((T) => Unit) => Unit)java.lang.Object with Traversable[T] Использование: scala> toTraversable(data).view.take(3).sum Generating 1 Generating 2 Generating 3 Generating 4 res1: Int = 6 Если в дебагере смотреть, Traversable генерируется до конца (так полагаю watcher'ы высчитываются и побуждают эту генерацию), но потом все таки выполняется take(3), но не как я бы ожидала. Там магия какая-то: внутри data, после выполнения f(i) мы перескакиваем обратно на foreach в traversable, а как бы цикл for(i <- 1 to 10), который внутри data, игнорируем. Я увидела breaks в traversable trait'е, но не осилила где они используются и как это работает. Anyone knows?

def invoke { try{ def f = (i:Int) => { if (enough) throw hitriiexception } data(f) }catch { case x:hitriiexception => } } типа того. брейк, ретурн - также через эксепшены работают - сахарок

без стектрейса эксепшн, замечу, так что перформанс падает меньше

Лол, думала я в data f(i) обернуть в try catch) но решила, что это уже извращенство)

ленивые генерилки лучше на https://github.com/functional-streams-for-scala/fs2/blob/series/0.10/docs/guide.md#building-streams делать

ленивые генерилки лучше на https://github.com/functional-streams-for-scala/fs2/blob/series/0.10/docs/guide.md#building-streams делать

Сам пользовал? Any pitfalls?

Мне fs2 очень понравился. Правда я других и не пробовал стримов.

я не пользовался, но одобряю

Сам пользовал? Any pitfalls?

пользовал, питфоллы: коллеги будут высмеивать за то что юзаешь (давно уже не) scalaz-streams, а также, что это серьёзная тулза для реактивных стримов а не просто локально тяп-ляп

А кто что использует у нас для тресинга и метрик?

А кто что использует у нас для тресинга и метрик?

один мой друг в одном банке использовал https://www.instana.com, но она не работала и пилот зафризили

я так подозреваю или открытие или бинбанк =)

я так подозреваю или открытие или бинбанк =)

наверняка

А кто что использует у нас для тресинга и метрик?

Был опыт с appdynamics, не советую. Kamon чуть лучше, но всеравно ужасен

А чем ужасен?

мы юзаем kamon, но тольку ту часть, где он через aspectjweaver вклинивается в переходы между потоками. таким образом прокидываем контекст между фьючами и акторами.

Ну руками народа все прописывать, стримы мониторить не умеет, Akka http через костыль работает с ним

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

тормозит, течет, хрен пойми как работает

метрики jmx?

your mileage may vary

метрики jmx?

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

и там всё прям плохо у нас было

а-ля включаешь репортинг в инфлюкс, и он просто смотрит на холостую actorsystem, которая внутри там где-то у кого-то, и всё равно течет