а никто чата по вопросам JavaEE не встречал на просторах телеграмма?

@jvmchat

Jakarta EE, попрошу извинить

@jvmchat

спасибо большое!

Jakarta EE, попрошу извинить

сорри, исправлюсь :)

Эх, либо я опять в глаза долблюсь, либо этот нюанс в документации несколько опущен

Kotlin property - это, по сути, поле с аксессорами, у тебя нет гарантий, что между двумя обращениями к полю не произойдёт изменение backing field, например из другого потока, отсюда и проблема. Мы обычно оборачиваем в какой-нибудь mutableField?. also()

Тогда в also у тебя гарантированно захваченная nonnull переменная

Type Checks and Casts: 'is' and 'as' - Kotlin Programming Language https://kotlinlang.org/docs/reference/typecasts.html#smart-casts

Ребят, а никто с сиквенсами на корутинах не баловался? У меня 2 вопроса: 1) он может быть конечным? Или по определению бесконечен? 2) если берёшь следующее значение несколькими потоками одновременно, то там внутри всё-равно же начинается concurrency и нужно корректно синхронизировать весь алгоритм получения следующего значения

Эх, либо я опять в глаза долблюсь, либо этот нюанс в документации несколько опущен

^

Ребят, а никто с сиквенсами на корутинах не баловался? У меня 2 вопроса: 1) он может быть конечным? Или по определению бесконечен? 2) если берёшь следующее значение несколькими потоками одновременно, то там внутри всё-равно же начинается concurrency и нужно корректно синхронизировать весь алгоритм получения следующего значения

Да, может, смотри реализацию sequencebuilder Да, конкарренси, все такое

И в целом, есть какие-нибудь бест практисы на тему ленивого форк джоина? Или я о чём-то странном мечтаю?

Ребят, а никто с сиквенсами на корутинах не баловался? У меня 2 вопроса: 1) он может быть конечным? Или по определению бесконечен? 2) если берёшь следующее значение несколькими потоками одновременно, то там внутри всё-равно же начинается concurrency и нужно корректно синхронизировать весь алгоритм получения следующего значения

что вы понимаете под "безконечен"? Он по сути ленив.

что вы понимаете под "безконечен"? Он по сути ленив.

Ну во всех примерах там в основном фибоначи и "дай первые 10", а у меня задача, ну допустим рюкзак через динамическое программирование, там конечное число вариантов

и я хочу сделать forEach

Я тут только что подумал, типа можно просто на некоторой итерации не делать yeld... ?

я так понимаю, он будет бесконечен до тех пор, пока есть кому принимать значение)

я так понимаю, он будет бесконечен до тех пор, пока есть кому принимать значение)

Ну вот и я так тоже понимаю на данный момент, но не всегда же пользователь знает сколько нужно

Я тут только что подумал, типа можно просто на некоторой итерации не делать yeld... ?

Блин, вообще вот это просто нужно будет попробовать... спасибо! =)

Сорян за использование чатика как уточку )

Хотя второй вопрос остался (про синхронизацию)

Сорян за использование чатика как уточку )

Ниче, тут все равно запрещают про дарт флудить, ты хоть по теме

Ребят, а никто с сиквенсами на корутинах не баловался? У меня 2 вопроса: 1) он может быть конечным? Или по определению бесконечен? 2) если берёшь следующее значение несколькими потоками одновременно, то там внутри всё-равно же начинается concurrency и нужно корректно синхронизировать весь алгоритм получения следующего значения

если ты читаешь из sequence из нескольких потоков, то ты что-то не то делаешь

ладно бы канал

Я тут только что подумал, типа можно просто на некоторой итерации не делать yeld... ?

судя по примеру, вариант вполне подходящий https://github.com/Kotlin/kotlin-coroutines/blob/master/examples/sequence/sequenceOfLines.kt

судя по примеру, вариант вполне подходящий https://github.com/Kotlin/kotlin-coroutines/blob/master/examples/sequence/sequenceOfLines.kt

Дааа, точно, спасибо, так и знал. ?

ладно бы канал

А разница?

А, не, я знаю разницу, с каналом не получится лениво

если ты читаешь из sequence из нескольких потоков, то ты что-то не то делаешь

Ну и вообще, а что такого?

A sequence that returns values through its iterator. итератор не всегда потокобезопасен

про каналы и "лениво" fun main(args: Array<String>) { val c = Channel<String>() launch { c.send("hello world") c.close() } runBlocking { for (msg in c) { println(msg) } } }

https://github.com/Kotlin/kotlinx.coroutines/issues/254

Роман объясняет, почему целиком лениво не получается.

о, большое спасибо, буду смотреть!

A sequence that returns values through its iterator. итератор не всегда потокобезопасен

тут да, согласен. даже в подавляющем числе случаев потокоНЕбезопасен

Ниче, тут все равно запрещают про дарт флудить, ты хоть по теме

Для этого есть флуд канал

ребят, подскажите плиз

нежно люблю типизированные языки, а котлин вообще ня

можно ли его сейчас применять на фронте?

надо у дедов спросить

(почему нет? что такое фронт?)

frontend

можно ли его сейчас применять на фронте?

можно, уже стабильный

frontend

в браузере или на сервере?

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

браузер

в браузере kotlin.js, на сервере kotlin.jvm

Ох уж эти влажные мечты

по поводу?

По поводу переиспользования кода на беке и фронте

у нас фронтэнды уже посматривают на котлин

ну не всего кода же

а DTO как минимум

Пока что, все кто это делает, страдают, имхо

один раз описали обьекты апишки, и юзаешь и там и там

а DTO как минимум

nexus решает

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

почему не TS?

как по мне, ts очень своеобразное решение

вообще с типизацией, на мой взгляд, в js скорее нерешаемая проблема

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

вообще с типизацией, на мой взгляд, в js скорее нерешаемая проблема

спорно, смотря что за проект

если у тебя там jquery и прочая хрень - тогда это бесполезно

а если реактовый SPA, то они даже в обычном жсе описывают типы для стейта

вот да. хорошо, есть DefinitelyTyped - но проблема в том, что не факт, что файл описания типов актуален

ERROR: S client not available

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

на любую либу подключенную

но я еще не игрался с kotlin/js, так что хз даже, может это не большая проблема

соотв, нужно ожидать, рассматривать и обновлять пару "библиотек" вместо одной. или хакать без типов, если в либе ценная правка бага или еще что-то, и надо необходимо обновить

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

чудеса с цепочкой запросов - отдельная жуть; слава партии за async/await

есть же корутины

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

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

естественно и прискорбно, что эти проблемы я ожидаю увидеть и в колтине под js

Подскажите, пожалуйста: есть вот такой код Socket(contact.currentIp, contact.currentPort).use { socket -> BufferedWriter(OutputStreamWriter(socket.getOutputStream())).use { out -> out.write(message) out.flush() BufferedReader(InputStreamReader(socket.getInputStream())).use { inp -> serverResponse = inp.readLine() } } } В прошлом проекте я использовал этот код, и отправка-приём сообщений происходили нормально. Сейчас же, сервер получает сообщение только есть убрать BufferedReader, в противном случае он видит что соединение произошло, но висит и ждёт сообщение.

Почему так может происходить? Убрал reader - сервер получает сообщение.

Всё, нашёл решение. Надо было out.write("$message\r")

Чтобы указать что на этом всё

Под windows это? А под Unix заработает "\r"?

Лучше после out.flush() закрыть } чтобы use закрыл стрим

Под windows это? А под Unix заработает "\r"?

Причем тут платформа?

Лучше после out.flush() закрыть } чтобы use закрыл стрим

Тогда всё закроется, я пробовал.

Просто как правило использование вот так в тупую \r может приводить к весьма странным последствиям на разных платформах. Ибо это carrige return а не \n. Просто readLine() принимает любой символ конца строки Можно \r заменить на out.newLine()

https://github.com/Kotlin/kotlinx.coroutines/issues/254

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

https://github.com/Kotlin/kotlinx.coroutines/issues/254

Но я так понимаю с sequence такой такой проблемы нет

Но я так понимаю с sequence такой такой проблемы нет

Sequence точно так же остановится после вычисления первого значения на yield, как и producer на send(). В этом контексте они, по-моему, равнозначны.

Не равнозначны.

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

не совсем. только в случае RendezvousChannel

@fogone вспоминая https://gist.github.com/fogone/e940de35f755c13299a65733c4b3be59#file-github-kt-L60 почему для параллельного map не сделать produce(context, capacity = parallel) { (0 until parallel).map { launch(context) { consumeEach { send(transform(it)) } } }.forEach { it.join() } } ?

Не равнозначны.

Роман пришёл и всех заинтриговал ) Я так понимаю неравнозначность будет в том что если у сиквенса запросить 10 значений он вычислит 10 и всё, а канал пойдёт вычислять 11 значение и затупит только на отсылке этого 11го, если не будет консьюмера

buildSequence там вообще своей жизнью живет

Роман пришёл и всех заинтриговал ) Я так понимаю неравнозначность будет в том что если у сиквенса запросить 10 значений он вычислит 10 и всё, а канал пойдёт вычислять 11 значение и затупит только на отсылке этого 11го, если не будет консьюмера

только что проверял, так и есть

только что проверял, так и есть

Круто, спасибо большое

Просто как правило использование вот так в тупую \r может приводить к весьма странным последствиям на разных платформах. Ибо это carrige return а не \n. Просто readLine() принимает любой символ конца строки Можно \r заменить на out.newLine()

у тебя iOS? везунчик, как я помню разделитель строки. \n Win, \r\n Nix, \r iOS при этом и на на многоих никсах, на винде 100%, и под iOS \n работала. Если такая проблемма, могу посоветовать подход из пхп EOL - который по сути берет систему, и от нее ставит разделитель, думаю можно через System прописать

и да, не забудь, если ты в exec(ляляля) влазишь, там может быть сложнее, пример, при подключении к COM порту прописании AT команд в модем, разделитель, это новая комманда, для отправки аргуменда нужно зажействовать Alt+Z