Телеграмм чат группы kotlin_lang страница 7898

parrot.ru

Рейтинг популярных групп и каналов

В рейтинге участвует:

групп:

каналов:

Виртуальный сервер на SSD - недорого!

Аренда выделенных и виртуальных серверов (VDS/VPS), хостинг, аренда IP-адресов, администрирование, круглосуточная поддержка

qwarta.ru подробнее

Резервное копирование с проверкой на вирусы!!!

Удобный сервис создания резервных копий на любой сервер сети интернет. Отслеживайте изменения, проверяйте на вирусы. Надежно защитите свой бизнес!

go.backupland.com

Выбираете сервер? Любая конфигурация на заказ!

Аренда физических серверов любых конфигураций под любые запросы - 1С бухгалтерия, игровые сервера, нагруженные проекты, интернет-магазины!

qwarta.ru подробнее

Size: a a a

Kotlin Community

3017 membersпожаловаться на группу

2019 December 05

AI

Arkadii Ivanov in Kotlin Community

Sergey Opivalov

Как вы находите в баду столько времени для опенсорс работы?)

Смотря на что) ribs и mvicore мы используем сами давно. На это выделяется время, даже есть отдельный человек. Reaktive я начал делать в своё удовольствие, сейчас уже тоже время выделяется. Стали использовать

источник

13:34пожаловаться #1

OY

Oleg Yukhnevich in Kotlin Community

https://github.com/badoo/Reaktive/blob/master/benchmarks/jmh/README.md

badoo/Reaktive

Kotlin multi-platform implementation of Reactive Extensions - badoo/Reaktive

я могу быть не прав, но предположу 2 вещи
- разное дефолтное количество потоков при flatMap
- runBlocking случайно не заставить collect на flatMap работать в одном потоке?

источник

13:35пожаловаться #2

AI

Arkadii Ivanov in Kotlin Community

Oleg Yukhnevich

я могу быть не прав, но предположу 2 вещи
- разное дефолтное количество потоков при flatMap
- runBlocking случайно не заставить collect на flatMap работать в одном потоке?

Я проверял вроде, всё было на отдельных потоках.

источник

13:36пожаловаться #3

K

Kopusha in Kotlin Community

ничего не хочу слышать, Бреслав на Keynote показал столбики, где Flow быстрее остальных Rx фреймворков!

источник

13:57пожаловаться #4

OY

Oleg Yukhnevich in Kotlin Community

Я проверял вроде, всё было на отдельных потоках.

я вот не уверен
в коллекте, там создаётся scope через coroutineScope - а следовательно, контекст должен просто наследоваться от runBlocking {}
https://pl.kotl.in/20ITxKl8o
вот, видно, что всё работает в BlockingEventLoop
если раскоментить строки 1 и 2
можно увидеть, как меняется поведение, и что диспатчер меняется

источник

13:58пожаловаться #5

OY

Oleg Yukhnevich in Kotlin Community

следовательно, логично, что тесты в 1 потоке для flow будут сильно медленнее N потоков в Rx

источник

13:59пожаловаться #6

OY

Oleg Yukhnevich in Kotlin Community

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

источник

14:00пожаловаться #7

AI

Arkadii Ivanov in Kotlin Community

Я видел что: 1. Все flow работали на разных потоках, 2. самый нижний collect вызывался с разных потоков

источник

14:01пожаловаться #8

RE

Roman Elizarov in Kotlin Community

Я ещё сравнивал (но не опубликовал) многопоточный merge (2-6 стримов в отдельных потоках), Flow в 30 медленнее чем RxJava

Многопоточный merge мы еще пока не оптимизировали от слова «совсем». Даже сама функция еще experimental.

источник

14:01пожаловаться #9

AI

Arkadii Ivanov in Kotlin Community

Многопоточный merge мы еще пока не оптимизировали от слова «совсем». Даже сама функция еще experimental.

Согласен

источник

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

RE

Roman Elizarov in Kotlin Community

https://github.com/badoo/Reaktive/blob/master/benchmarks/jmh/README.md

badoo/Reaktive

Kotlin multi-platform implementation of Reactive Extensions - badoo/Reaktive

А тут вообще сравнивается мягкое с холодным - асинхронный flow, поддерживающий backpressure, сравнивается с observable, в котором никакого backpressure нет и в помине.

источник

14:05пожаловаться #11

AI

Arkadii Ivanov in Kotlin Community

А тут вообще сравнивается мягкое с холодным - асинхронный flow, поддерживающий backpressure, сравнивается с observable, в котором никакого backpressure нет и в помине.

Сравниваем Observable RxJava и Reaktive с тем что есть во Flow

источник

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

OY

Oleg Yukhnevich in Kotlin Community

Я видел что: 1. Все flow работали на разных потоках, 2. самый нижний collect вызывался с разных потоков

самый нижний collect вызывался с разных потоков это как?
Если он как раз должен вызываться на одном?

источник

14:07пожаловаться #13

RE

Roman Elizarov in Kotlin Community

Аналог flow в rxjava это flowable

источник

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

AI

Arkadii Ivanov in Kotlin Community

Oleg Yukhnevich

самый нижний collect вызывался с разных потоков это как?
Если он как раз должен вызываться на одном?

Он может вызываться на разных, но не одновременно

источник

14:08пожаловаться #15

AI

Arkadii Ivanov in Kotlin Community

Аналог flow в rxjava это flowable

Да, но цель наших бенчмарков сравнить именно с RxJava Observable. А Flow там за компанию.

источник

14:09пожаловаться #16

OY

Oleg Yukhnevich in Kotlin Community

Он может вызываться на разных, но не одновременно

а, понял, да, это в одной корутине, всё норм

источник

14:09пожаловаться #17

OY

Oleg Yukhnevich in Kotlin Community

Да, но цель наших бенчмарков сравнить именно с RxJava Observable. А Flow там за компанию.

для observable не ConfaltedBroadcastChannel самое близкое?

источник

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

AI

Arkadii Ivanov in Kotlin Community

Oleg Yukhnevich

для observable не ConfaltedBroadcastChannel самое близкое?

Возможно, но они вроде горячие

источник

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

V

Vladimir in Kotlin Community

Да, но цель наших бенчмарков сравнить именно с RxJava Observable. А Flow там за компанию.

ну такое, что Flow там за компанию. В заблуждение ведь вводит обывателей

источник

14:13пожаловаться #20