Телеграмм чат группы scala

ничего лучше реактив драйвера не видел, но модуль реактив-fs2 непростительно медленный. для себя пилил реализацию чуть пошустрее https://github.com/dokwork/fast-reactive-fs2

GitHub

dokwork/fast-reactive-fs2

Faster jvm-only implementation of the reactive streams for fs2. - dokwork/fast-reactive-fs2

В двух словах, за счёт чего перфоманс буст по сравнению с родным фс2-реактив?

источник

18:12пожаловаться #12

VP

Vladimir Popov in Scala User Group

не ранится IO на каждый элемент как здесь:

def onNext(a: A): Unit = {
    nonNull(a)
    sub.onNext(a).unsafeRunAsync
  }

запрашивается пачка значений, а не 1 как тут:

case OnDequeue(r) => {
        case Idle(sub)              => WaitingOnUpstream(sub, r) -> F.delay(sub.request(1))
...

https://github.com/functional-streams-for-scala/fs2/blob/master/reactive-streams/src/main/scala/fs2/interop/reactivestreams/StreamSubscriber.scala

GitHub

functional-streams-for-scala/fs2

Compositional, streaming I/O library for Scala. Contribute to functional-streams-for-scala/fs2 development by creating an account on GitHub.

источник

18:16пожаловаться #13

OO

Oleksandr Olgashko in Scala User Group

подскажите следующее: есть коллекция, для обработки которой надо сконвертировать в массив (легаси код, абузящий мутабельность(
как сконвертировать массив в точно тот же тип? (скала < 2.13)

источник

19:10пожаловаться #14

IA

Ivan Aristov in Scala User Group

Oleksandr Olgashko

подскажите следующее: есть коллекция, для обработки которой надо сконвертировать в массив (легаси код, абузящий мутабельность(
как сконвертировать массив в точно тот же тип? (скала < 2.13)

Нужен код

источник

19:12пожаловаться #15

Oℕ

Oleg ℕizhnik in Scala User Group

Oleksandr Olgashko

подскажите следующее: есть коллекция, для обработки которой надо сконвертировать в массив (легаси код, абузящий мутабельность(
как сконвертировать массив в точно тот же тип? (скала < 2.13)

CanBuildFrom[F[A], B, F[B]]

источник

19:12пожаловаться #16

OO

Oleksandr Olgashko in Scala User Group

Oleg ℕizhnik

CanBuildFrom[F[A], B, F[B]]

а откуда типы взять?

источник

19:13пожаловаться #17

OO

Oleksandr Olgashko in Scala User Group