С одним каналом не то

На выходе один канал конечно

Причем это все отлично работает если убрать параллельное выполнение

Ладно, я ещё поковыряю, спс

Вообще каналы не ломают параллелизм сами по себе (если только не превышать размер очереди).

Вообще каналы не ломают параллелизм сами по себе (если только не превышать размер очереди).

Да, именно в этом проблема, но пока не могу разобраться как это правильно организовать

Проблема в том, что хотелось флоу организовать, потому что надо мапить, фильтровать, дистинкт, флэтмап и тд

Что-то тебя RX не отпускает. Зачем все это, если можно писать императивный код с циклами… ?

Ну в 0.20 добавили кучу функций над каналами, почему бы и нет?

Что-то тебя RX не отпускает. Зачем все это, если можно писать императивный код с циклами… ?

Хорошая шутка, но вот сейчас чот не смешно ?

Ну пиши ФП на функциях и композируй их - получается то же самое. RX все равно почти никто не умеет правильно готовить, вечно в каждом втором flatMap лезут с сайд-эффектами, а потом это нихрена не композируется.

Ну пиши ФП на функциях и композируй их - получается то же самое. RX все равно почти никто не умеет правильно готовить, вечно в каждом втором flatMap лезут с сайд-эффектами, а потом это нихрена не композируется.

Так и сделал, проблема организовать это параллельно

Я вот что-то не пойму какие там могут быть проблемы с параллельностью. Видимо нужен конкретный пример.

https://github.com/GoogleChrome/puppeteer вот где я наверное заюзаю kotlin/js

https://github.com/GoogleChrome/puppeteer вот где я наверное заюзаю kotlin/js

Есть селениум + headless-chrome. Зачем node то? ?

нормально работают вместе?

Вижу, что const val компилируется в финальный стринг, можно как-нибудь сказать котлину, что переменные хочется заинлайнить?

нормально работают вместе?

Как сейчас хз, юзал это когда headless хром еще не было, а был только фантомжс. Мне было норм, а теперь говорят стало еще лучше.

https://www.meetup.com/KyivKUG/events/246710666/ в киеве сегодня котлин митапчик

Может кто помочь разобраться с retrofit?

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

А у кого-то были проблемы с котлином (data class) и dbflow? Ругается на отсутствие дефолтного конструктора, на приватность поля, которое публичное.

Может кто помочь разобраться с retrofit?

Многие могут, лучше сразу вопрос.

А у кого-то были проблемы с котлином (data class) и dbflow? Ругается на отсутствие дефолтного конструктора, на приватность поля, которое публичное.

UPD: Эта дрянь не может в геттеры для Boolean в котлине. Сделал isBooleanProperty аксессор – заработало. Копец.

Я вот что-то не пойму какие там могут быть проблемы с параллельностью. Видимо нужен конкретный пример.

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

можно ведь как то уместить в 1 строчку? if (allow) { confirmSession() cancelNotification() } else { cancelSession() cancelNotification() }

Убери переносы строк, добавь точку с запятой

и убери дублирование

и убери дублирование

?

cancelNotification можно и после кондишена заюзать

Тогда убираются фигурные скобки

И все это превращается в две + одну строку

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

такое? :) suspend fun parallel(vararg actions: suspend () -> Unit) = actions.map { async { it() } }.forEach { it.await() }

if (allow) confirmSession() else cancelSession() cancelNotification()

Как-то так, в общем.

И точки с запятой можно убрать.

if else по идее, можно и в одну строку написать. Тут недлинно, вроде.

такое? :) suspend fun parallel(vararg actions: suspend () -> Unit) = actions.map { async { it() } }.forEach { it.await() }

И где тут параллелизм?

if (allow) confirmSession() else cancelSession() cancelNotification()

Да.

И точки с запятой можно убрать.

Я еще гайд от JB по кодестайлу не читал, так что сам не шарю)

К тому же разговор был о каналах

@fly_style да, спасбо, так и написал уже после первых 2 замечаний ;)

@fly_style да, спасбо, так и написал уже после первых 2 замечаний ;)

?

Смотря что подразумевается под параллелизмом -- функция запускает пачку корутин в CommonPool и дожидается их все. Касательно того, что речь о каналах шла, запамятовал.

Смотря что подразумевается под параллелизмом -- функция запускает пачку корутин в CommonPool и дожидается их все. Касательно того, что речь о каналах шла, запамятовал.

Да, запускает, это правда, но разговор был про другое

Ну каналы в корутинах ровно то-же самое, что и BlockingQuieue в тредах. Это просто инструмент для обмена данными, он никак не организует параллелизм сам по себе.

Смотря что подразумевается под параллелизмом -- функция запускает пачку корутин в CommonPool и дожидается их все. Касательно того, что речь о каналах шла, запамятовал.

есть под рукой код как это делать?

есть под рукой код как это делать?

Что именно? Задачу из процитированного сообщения я решил для себя функцией, приведенной чуть выше.

Что именно? Задачу из процитированного сообщения я решил для себя функцией, приведенной чуть выше.

немного не то что хотелось

А кто может посоветовать по ORM для Android что-нибудь, что дружелюбно с котлином работает?

Imposibru ?... (не бывает таких)

те, которые умеют наследоваться от data классов

рум норм вроде

те, которые умеют наследоваться от data классов

Так точно. Хочу одну модельку для ответа с сервера и бд, и не хочу в сотый раз писать кучу всякой дряни для SQL

нашел к слову народ в гугл группах, которые через jdbc и jooq работают :D

Так точно. Хочу одну модельку для ответа с сервера и бд, и не хочу в сотый раз писать кучу всякой дряни для SQL

штука в том, что от дата классов наследоваться нельзя. а все существующие ORM генерируют прокси-классы, наследуясь от твоих объектов, следовательно таких нет неплохие — room, requery

Мдя. Ладно, спасибо.

Зачем использовать дата-классы здесь?

Мдя. Ладно, спасибо.

С room только может быть проблема в случае универсальной модели для БД и сервера: room не может в @Entity распознать List<*>, в отличие от requery.

You can inherit a data class from a non-data class. Inheriting a data class from another data class is not allowed because there is no way to make compiler-generated data class methods work consistently and intuitively in case of inheritance.

You can inherit a data class from a non-data class. Inheriting a data class from another data class is not allowed because there is no way to make compiler-generated data class methods work consistently and intuitively in case of inheritance.

ну да, и это абсолютно логично

С room только может быть проблема в случае универсальной модели для БД и сервера: room не может в @Entity распознать List<*>, в отличие от requery.

Реквери - «так себе» либа

Реквери - «так себе» либа

аналогов, к сожалению, нет

аналогов, к сожалению, нет

Room

Room

мне бы под сервак

мне бы под сервак

Hibernate

Hibernate

не люблю xml

не люблю xml

Там аннотации есть как-бы

мы ж не в 2005

лол

рефлексию тоже не хочу

мне нравится идея генерации кода как в реквери

рефлексию тоже не хочу

kwery

мне нравится идея генерации кода как в реквери

А ты посмотри что он генерирует и удивись

не люблю xml

юзаю хибернейт без (ну почти без) xml, брат жив

kwery

вроде написано, что не юзает рефлекшн, а в зависимостях есть

вроде написано, что не юзает рефлекшн, а в зависимостях есть

хм, взгляну, использует ли по факту

мне бы под сервак

jooq один из лучших вариантов

++

как исправить

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

maven { url "https://jitpack.io" }

все есть ..

repositories { mavenCentral() maven { url "https://jitpack.io" } } dependencies { compile 'com.github.goxr3plus:java-google-speech-api:V2.1' compile "org.jetbrains.kotlin:kotlin-stdlib:$kotlin_version" testCompile group: 'junit', name: 'junit', version: '4.12' }

ну фиг его знает, проблема именно с этой зависимостью

очень странно видеть V2.1

но все честно, там действительно такая версия https://jitpack.io/com/github/goxr3plus/java-google-speech-api/V2.1/maven-metadata.xml

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

очень странно видеть V2.1

там должна быть по новее ?

repositories { mavenCentral() maven { url "https://jitpack.io" } } dependencies { compile 'com.github.goxr3plus:java-google-speech-api:V2.1' compile "org.jetbrains.kotlin:kotlin-stdlib:$kotlin_version" testCompile group: 'junit', name: 'junit', version: '4.12' }

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