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

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

KA

Kira Alche in Kotlin JVM

Нашел кажись

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

2018 October 03

IH

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

21:40пожаловаться

AE

Alexandr Emelyanov in Kotlin JVM

Два пути:
1. Идем читать гугл по запросу java io streams with progress bar
2. Идем читать гугл по запросу kotlinx-io with progress bar

22:36пожаловаться

AE

Alexandr Emelyanov in Kotlin JVM

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

Либо читаем и изучаем первое, потом второе

22:36пожаловаться

2018 October 04

IH

Alexandr Emelyanov

Либо читаем и изучаем первое, потом второе

👍
Спасибо

06:51пожаловаться

LK

L K in Kotlin JVM

на ktor можно поднять websocket сервер, как там обрабатывать события типа on- connect, close, error
сообщения все идут с incoming: ReceiveChannel<Frame>
как другие обрабатывать ?

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

DT

Dmitry Tsydzik in Kotlin JVM

можно заюзать TeeOutputStream, засплитить вывод в свою реализацию OutputStream-а, в котором считать прогрес

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

AS

Andrey Sidorenko in Kotlin JVM

Не слишком ли громоздко?
Создать свою реализацию OutputStream и переопределить методы вывода, и никакие TeeOutputStream не нужны

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

DT

Dmitry Tsydzik in Kotlin JVM

а кто в файл будет писать?

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

AS

Andrey Sidorenko in Kotlin JVM

Грубо говоря:

ProgressOutput(OutputStream os) {
this.originalStream = is;
}

...
void write(byte[] data) {
bytesWritten += data.length();
this.originalStream.write(data);
}

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

DT

Dmitry Tsydzik in Kotlin JVM

тоже верно, если забить на srp

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

2018 October 07

IH

Кто-то с корутинами работал?
Как можно асинхронно прочитать inputstream и так же записать эго в файл

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

AE

Alexandr Emelyanov in Kotlin JVM

И опять берем гугл и вбиваем kotlin corutines io

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

RH

Ruslan Hanza in Kotlin JVM

Кто-то с корутинами работал?
Как можно асинхронно прочитать inputstream и так же записать эго в файл

launch {
    var data = read()
    writeToFile(data)
}
...
suspend fun read(): Data {
...
}

suspend fub writeToFile(data: Data) {
...
}

Ну и твоя реализация чтения и записи в этих методах.
Вопрос как сделать это асинхронно? Или как вообще читать и писать? Несколько задачи асинхронно, может, надо запускать и awaitить их? Конкретики бы

13:08пожаловаться

IH

Ruslan Hanza

launch {
    var data = read()
    writeToFile(data)
}
...
suspend fun read(): Data {
...
}

suspend fub writeToFile(data: Data) {
...
}

Ну и твоя реализация чтения и записи в этих методах.
Вопрос как сделать это асинхронно? Или как вообще читать и писать? Несколько задачи асинхронно, может, надо запускать и awaitить их? Конкретики бы

Спасибо, попробую.
Глобально нужно сделать многопоточное чтение и запись

13:10пожаловаться

BP

Bogdan Panchenko in Kotlin JVM

Спасибо, попробую.
Глобально нужно сделать многопоточное чтение и запись

тут не совсем корунтины, гуглите NIO, ведь IO дефакто синхронное

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

IH

Bogdan Panchenko

тут не совсем корунтины, гуглите NIO, ведь IO дефакто синхронное

NIO+ corutines , нужно как-то связать ))

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

BP

Bogdan Panchenko in Kotlin JVM

NIO+ corutines , нужно как-то связать ))

сейчас корунтины в 1.2 и 1.3 немного изменены, но раньше был (1.2) корунтин билдер async + на нужные функции вешается suspend - это значит что функция может "заснуть" (прервать выполнения)

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

IH

Bogdan Panchenko

сейчас корунтины в 1.2 и 1.3 немного изменены, но раньше был (1.2) корунтин билдер async + на нужные функции вешается suspend - это значит что функция может "заснуть" (прервать выполнения)

Понял спасибо, буду разбираться