Хотя бывает и такое что у этой строки длина была 123, эту длину вы считали на место удалённого инта, а дальше парсинг считал первые 4 байта стоки, а там оказалось число 100, ну и дальше он вполне считает эту строку. И на выходе у вас будет головная боль по определению откуда ж такой монстр приехал

Но это если схема не передаётся вместе с телом, но тогда какая разница между json?

Как подписаться на канал в корутинах?

Судля по доке https://github.com/Kotlin/kotlinx.coroutines/blob/master/reactive/coroutines-guide-reactive.md#subscription-and-cancellation нужно использовать RxJava

Без этого ни как?

С чего бы это? Вот код, который по смещению 42 ожидает инт, вы этот инт удаляете, за ним идёт строка. Получается этот код откусит от строки 4 байта

Почитайте, как протобуф устроен, там есть optional поля. Avro, насколько я слышал, вообще сильно заточен на поддержку обратной совместимости.

Почитайте, как протобуф устроен, там есть optional поля. Avro, насколько я слышал, вообще сильно заточен на поддержку обратной совместимости.

Ну дык, это нужно сразу думать что это поле возможно будет удалено и помечать optional, я рассказывал в целом как ситуация обстоит

в протобуфе лучше придерживаться политики делать все поля optional, так как будущего никто не знает

Ну просто тут же все за перфоманс, вот бенчмарки https://github.com/eishay/jvm-serializers/wiki

Всё как я и говорю, если нужна совместимость, то нужна схема в сообщении (ну или таблица смещений в начале сообщения), а значит что у вас большого выигрыша не получится

optional поля дают копеечный overhead фактически там просто id полей, которые можно поместить в один байт, или даже в несколько бит, точно не помню это совершенно несравнимо с json, где все в виде строк например, по трафику выигрыш просто в разы, если не в десятки раз

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

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

Ты же вкурсе что обычно gzip пересылают?

Вы тут вообще копейки обсуждаете

optional поля дают копеечный overhead фактически там просто id полей, которые можно поместить в один байт, или даже в несколько бит, точно не помню это совершенно несравнимо с json, где все в виде строк например, по трафику выигрыш просто в разы, если не в десятки раз

Вооо, id, а потом появляется ещё один в середине, что происходит тогда с этими id?

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

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

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

Не, про этот кейс - понятно, я про именно удаление устаревшего поля

Конечно нужно почитать, но пока это выглядит как магия: вот у вас есть 10 полей, мы их проиндексировали 1,2,3... и передаём с номером, далее впихнули ещёодно поле в начало, как их так проиндексировать чтобы ничего не сломалось, при условии что мы ничего не знаем о старой версии

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

Конечно нужно почитать, но пока это выглядит как магия: вот у вас есть 10 полей, мы их проиндексировали 1,2,3... и передаём с номером, далее впихнули ещёодно поле в начало, как их так проиндексировать чтобы ничего не сломалось, при условии что мы ничего не знаем о старой версии

В прото, насколько я помню, номера полей задаются явно.

Удаление и добавление новых - это самый геморой

В прото, насколько я помню, номера полей задаются явно.

Ааа, ну значит это возложено на программиста

Конечно нужно почитать, но пока это выглядит как магия: вот у вас есть 10 полей, мы их проиндексировали 1,2,3... и передаём с номером, далее впихнули ещёодно поле в начало, как их так проиндексировать чтобы ничего не сломалось, при условии что мы ничего не знаем о старой версии

там всем полям назначаются id, причем навсегда a: 1 b: 2 c: 3 в потоке идет номер поля, потом данные: 1, a, 2, b, 3, c если удалил b, то придет: 1, a, 3, c И ничего не сломается, b выставится в default

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

В json всё просто: мапка, берём по имени, всё. Обратная совместимость на этом уровне отличная и достаточно интуитивно понятная

В json всё просто: мапка, берём по имени, всё. Обратная совместимость на этом уровне отличная и достаточно интуитивно понятная

Аналогично у протобаф, только ключи — числа.

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

там всем полям назначаются id, причем навсегда a: 1 b: 2 c: 3 в потоке идет номер поля, потом данные: 1, a, 2, b, 3, c если удалил b, то придет: 1, a, 3, c И ничего не сломается, b выставится в default

Ну я и говорю, если это на программиста возложено, то это понятно

Аррр, числа - это жесть, у нас крио и тоже есть пререгистрация, чтобы инты передавать вместо имени класса, так вот это ТАКОЙ ГЕМОРОЙ

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

Ну ок, я верю что в протобафе как-то поумнее сделано

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

Я чувствую, что пора добавить сравнение с бинарными сериализатором, какой брать? Протобаф?

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

Но в целом, вариантов не много, либо сам нумеруешь, либо мучаешься

Как подписаться на канал в корутинах?

Можно просто в цикле читать через receive() Если канал будет пустым, то корутина просто заснет

Я чувствую, что пора добавить сравнение с бинарными сериализатором, какой брать? Протобаф?

Protostuff, cap'n'proto, thrift

Я чувствую, что пора добавить сравнение с бинарными сериализатором, какой брать? Протобаф?

Вот эти все https://github.com/eishay/jvm-serializers/wiki

Я чувствую, что пора добавить сравнение с бинарными сериализатором, какой брать? Протобаф?

protobuf, avro

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

Ну или если кто-нибудь поможет, то все добавим)

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

кстати сейчас подумал, что если отсортировать поля по возрастанию id и использовать gamma coding, то для большинства полей id вообще можно одним битом закодировать

Можно просто в цикле читать через receive() Если канал будет пустым, то корутина просто заснет

Но тогда у меня заблокируется поток.

Почитай, что такое “корутины” и как они работают. Thread не заблокируется, уснет отдельно корутина.

Он заблокируется в цикле

Вы тут вообще копейки обсуждаете

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

fun main(args: Array<String>) = runBlocking<Unit> { val channel = Channel<Int>() launch { for (x in 1..5) { channel.send(x * x) } } println("start") for (i in channel) { println("get $i") } println("end") }

до end Не дойдет.

async { for (i in channel) println("get $i") }

Это работает. Спасибо!

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

Я уверен, что вы не гугл

Есть простой принцип, вспомните, что вы не гугл

до end Не дойдет.

так ты закрой канал

launch { for (x in 1..5) { channel.send(x * x) } channel.close() }

Есть простой принцип, вспомните, что вы не гугл

я знаю что я не гугл, и что из этого следует? протобуф используют очень много где за пределами гугла

async { for (i in channel) println("get $i") }

лучше launch)

так ты закрой канал

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

и вообще нужен join в его примере тогда, а то он дойдет до end и выйдет

лучше launch)

Тем что исключение не пропадет или еще есть что-то?

Тем что исключение не пропадет или еще есть что-то?

семантически лучше, async то deferred возвращает и его нужно дождаться потом

семантически лучше, async то deferred возвращает и его нужно дождаться потом

А launch Job (иа defered на следуется от job) и его тоже надо дожидаться

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

а можно конкретнее что требуется?

А launch Job (иа defered на следуется от job) и его тоже надо дожидаться

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

Ну да, это только если семантическая разница, так то они фактически почти одно и тоже

а можно конкретнее что требуется?

Что то типа екселя. Есть ячейки с параметрами. При из изменении должны меняться данные в других ячейках

ERROR: S client not available

нужны отслеживаемые переменные. Вот при помощи каналов хочу их огранизовать.

тогда ты на верном пути)

Что то типа екселя. Есть ячейки с параметрами. При из изменении должны меняться данные в других ячейках

Rx так и просится

Rx так и просится

зачем?

Я начал на Rx делать, а потом про корутины подсказали, что есть каналы. Вот пытаюсь на корутинах сделать. А то rx со всем его зоопарком оператором тяжело дается.

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

если нужно реагировать сразу во многих местах то делаешь BroadcastChannel

Ну да, это только если семантическая разница, так то они фактически почти одно и тоже

Кстати, тоже интересен вопрос, в чем разница помимо семантики, и что будет плохого, если использовать async в качестве fire and forget

Кстати, тоже интересен вопрос, в чем разница помимо семантики, и что будет плохого, если использовать async в качестве fire and forget

в целом ничего, это как let и also

где async тебе вернет еще результат (как let), а с launch видно что не нужно ждать результата

Кстати, тоже интересен вопрос, в чем разница помимо семантики, и что будет плохого, если использовать async в качестве fire and forget

launch еще по умолчанию выведет в консоль stacktrace необработанного-исключения, а async нет (и ты не узнаешь о ошибках, если сам не будешь их логировать)

ну эт если await не вызвать

поэтому и говорю что async надо юзать только в связке с await

launch еще по умолчанию выведет в консоль stacktrace необработанного-исключения, а async нет (и ты не узнаешь о ошибках, если сам не будешь их логировать)

да, это очень существенно в общем не надо асинком стрелять и забывать )

Делаю “свой логер” на inline функции и вопрос про lineNumber для inline-лябды inline fun info(msg: () -> String) { if (!BuildConfig.DEBUG) return val element = Exception().stackTrace[1] println("LOGX :: ${element.fileName}:${element.lineNumber} :: ${msg()}") } В Kotlin все так же нельзя получить ее оригинальное значение? (сейчас оно указывает за груницу файла)

return """${it.firstName} .${it.lastName.first().toUpperCase()} .${it.secondName.first().toUpperCase()}""" как тут удалить перенос строки?

return """${it.firstName} .${it.lastName.first().toUpperCase()} .${it.secondName.first().toUpperCase()}""" как тут удалить перенос строки?

.trimIndent() ?

nea

регекспом?

а нету тут поддержки от котлина в 3 ковычках ?

return """${it.firstName} .${it.lastName.first().toUpperCase()} .${it.secondName.first().toUpperCase()}""" как тут удалить перенос строки?

"""123 |1231 |testes """.trimMargin() только важно | ставить вначале, чтобы оно до этого символа вырезало

ты запускал?

у меня не работает

.replace("\n", "") нужен что-ли?

это то ладно, а в ковычках ни как разрулить?

val n = "123" + "1231" + "testes" Тройные кавычки -- мультилайн строка, логично, что она сохраняет переносы.

И да, в идее, если ты в обычном строковом литерале жмёшь Enter, вот это вот " +\n" среда поставит сама.

А можно как-то подписать именно на событие “закрытие канала” у Channel<T> Те при закрытие надо сразу закрыть и сторонний “ресурс”, а не ждать очередной попытки записать.

проходил кто Kotlin Koans? Не могу понять, что в этом коде не так: https://pastebin.com/gN2JESb3 при попытке проверить решение выкидывает просто "compilation failed" IDE почему-то подсвечивает мне "in" красным