"Chunk up the stream into groups of elements received within a time window, or limited by the given number of elements, whichever happens first." - это влияет на водопад

если его ответвить, ни на что он влиять не будет

"водопад", блин

опять хранить ненужные буферы неиспользуемых данных?

опять?

каких данных?

если не хочешь хранить, разрешаю не хранить

пусти его в быстрый Sink и всё

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

по сути нужен каждый тысячный элемент, или каждый элемент за 30 секунд. с groupWithin мы получаем все эти элементы ради последнего

я понимаю что тут можно conflate использовать

если не хотите хранить Seq, можно использовать batch

по сути нужен каждый тысячный элемент, или каждый элемент за 30 секунд. с groupWithin мы получаем все эти элементы ради последнего

тогда dropWithin

хотя, вероятно, он разово дропнет

короче, просто batch

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

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

вот это на самом деле основная забота

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

всё ж alsoTo и простейший Sink из стандартных компонент мог бы быть проще

пробую

ну вот пример без накопления`Seq` val res = Source(1L to 1000000L) .alsoTo(Flow[Long].splitAfter(_ % 10000 == 0) .take(1) .mergeSubstreams .to(Sink.foreach { i ⇒ println(s"processed $i") })) .runWith(Sink.fold(0L)(_ + _)) res.foreach(x ⇒ println(s"result is $x"))

Oleg ты то doobie не юзаешь?

Oleg ты то doobie не юзаешь?

нет

жаль

а в скале есть конструкции типа apply/also/let/run/with как в котлине? куда посмотреть?

а что делают эти конструкции в котлине?

у нас тут всё же не котлиночат, не все в курсе :)

а сори, ща)

http://beust.com/weblog/2015/10/30/exploring-the-kotlin-standard-library/ пару примерчиков глянуть можно

http://stackoverflow.com/questions/35083457/function-type-with-receiver-in-scala пишут что нельзя так баловаться с function reciever. врут?

не, из коробки такого вроде нет

но выглядит как что-то несложно реализуемое при желании на макросах

понял, спасибо

let вообще можно сделать банальным имплицитом

5.let { it + 5 } == 10

а что она делает

а ну да, эт просто имплисит функция

для Int в твоем случаее

with(foo) {...} можно заменить на {import foo._ ...}

Ща придет Олег и расскажет про котов)

но foo для этого должна быть stable reference

а что она делает

обьект из которого вызвали уходит как аргумент в лямбду и на выход идет то что вернула лямбда

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

обьект из которого вызвали уходит как аргумент в лямбду и на выход идет то что вернула лямбда

я понял)

да там весь этот сахар через импилиситы делается на раз

это такой способ форсить котлин в скалочяте? :)

это такой способ форсить котлин в скалочяте? :)

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

это такой способ форсить котлин в скалочяте? :)

да пусть, не жалко

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

?

ребзя, а в идее всегда была функция "desugar scala code" ?

вот например такие кострукции удобно писать OkHttpClient.Builder() .addInterceptor(HttpLoggingInterceptor().apply { level = BODY }) .build()

вопрос на засыпку

если кто смотрел doobie

Oleg особенно ты, любитель котов

че сразу скотов, дуби любит всех

как сделать сохранение one-to-many через 3 таблицы в один for

)

не понимаю нахера батч возвращает Stream[ConnectionIo,A]

да там весь этот сахар через импилиситы делается на раз

не весь там основная фишка типа "запустить в скоупе, опуская имя значения"

updateMany в смысле?

ага

updateMany в смысле?

или updateManyWithGeneratedKeys

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

ну всандаль туда runLog и будет тебе вектор

хм

а эт идея

@clayrat а у тебя тоже совсем с подствекой плохо?

подсветка и манатки несовместны, это не первый год известно

ERROR: S client not available

меня не манатки напрягаю

а Fragment

вот например такие кострукции удобно писать OkHttpClient.Builder() .addInterceptor(HttpLoggingInterceptor().apply { level = BODY }) .build()

OkHttpClient( interseptors = Seq( HttpLoggingInterceptor( level = Level.Body)))

а, это тоже известный баг

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

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

OkHttpClient( interseptors = Seq( HttpLoggingInterceptor( level = Level.Body)))

а если в HttpLoggingInterceptor нет параметра level?

HttpLoggingInterceptor().apply { level = BODY } == val interceptor = HttpLoggingInterceptor() interceptor.level = BODY

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

а монадки нормально кстати светит

а если в HttpLoggingInterceptor нет параметра level?

HttpLoggingINteceptor().copy(level = Level.Body)

HttpLoggingInterceptor().apply { level = BODY } == val interceptor = HttpLoggingInterceptor() interceptor.level = BODY

я понимаю

параметра нет, но он есть?

а если в HttpLoggingInterceptor нет параметра level?

или withLevel( Level.Body)

или withLevel( Level.Body)

что такое withLevel?

@clayrat еще блин с ошибками там не круто

что такое withLevel?

какой-нибудь метод, который объявил тот человек, который создавал класс вместо мутабельного говна level

https://www.scala-lang.org/blog/2017/03/14/scala-native-0.1-is-here.html

дык давно ж

я разве не писал?

может быть пропустил

примечательно что статья от 14ого числа

@gurinderu а что у них с многопоточностью?

многопоточность есть

с 1 потоком ?

шикарно

я этот вопрос ковырял, собсвтвенно я сейчас делаю omr обвязку

This is, of course, completely typical of the Scala community: marketing material that gives the impression something is more complete or better supported than it really is, to be subsequently justified by legalistic parsings of the original statement. I'm sure we'll be hearing plenty about how stupid a person would have to be to assume "support for the whole Scala language" could possibly refer to threads or libraries.

с реддита

ответь ему что-то конструктивное, а то в топ идет

да пусть идет

а как же маркетинг, пиар, вот это все?

а где такое на реддите?