ты делаешь что то не так

а как надо

задачу опиши что ты делаешь для начала

кароч

нужен манагер загрузок с абортами

андройд?

само собой

юзаю ретрофит для аплоада и fuel для загрузки

это вообще нормально?

чем стандартный манагер андройда не подходит?

чем стандартный манагер андройда не подходит?

временная загрузка файлов

только для просмотра

пошло все в жепу буду говнокодить

пошло все в жепу буду говнокодить

Это точно должно быть в kotlin community?

Это точно должно быть в kotlin community?

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

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

Во-первых, для офтопа есть специальный чатик (например @pofftop), во-вторых, нет необходимости так реагировать на замечания по делу.

тут два вопроса про то как использовать okhttp с корутинами были, покажу как я использовал (cc @InsanusMokrassar @Vorkytaka) Для начала нам нужен адаптер для функции enqueue, который использует callback чтобы сделать suspend функцию: class OkHttpException( val request: Request, val exception: Exception ) : RuntimeException(exception) suspend fun Call.await(): Response = suspendCoroutine { cont: Continuation<Response> -> this.enqueue(object : Callback { override fun onResponse(call: Call, response: Response) { cont.resume(response) } override fun onFailure(call: Call, exception: IOException) { cont.resumeWithException(OkHttpException(call.request(), exception)) } }) } Далее нам нужно... Да в общем-то и все, теперь можно брать и использовать: val response = okHttpClient.newCall(request).await() И вот например задача Алексея: fun muchFun(request: Request): Response = runBlocking { okHttpClient.newCall(request).await() }

Добрый день. Можно ли каким-то образом при map'е коллекции ставить условие с различными ихсодами? Т.е. что-то вроде этого list.map{ item -> if (item.property == smth) then item.anotherProperty = 10 else item.anotherProperty = 20} Стандартным способом не поулчается, но может есть какое-то хитрое решение? Есть вариант сделать 2 коллекции из 1 и для каждой свой фильтр под необходимое услвоие, но если будет больше чем 2 условия, то под каждое нужно будет новую операцию с коллекцией писать. Может есть какое-то способо получше?

Добрый день. Можно ли каким-то образом при map'е коллекции ставить условие с различными ихсодами? Т.е. что-то вроде этого list.map{ item -> if (item.property == smth) then item.anotherProperty = 10 else item.anotherProperty = 20} Стандартным способом не поулчается, но может есть какое-то хитрое решение? Есть вариант сделать 2 коллекции из 1 и для каждой свой фильтр под необходимое услвоие, но если будет больше чем 2 условия, то под каждое нужно будет новую операцию с коллекцией писать. Может есть какое-то способо получше?

Ну если на выходе один и тот же тип - то вполне нормально запихнуть это в map с if-ом

Ну если на выходе один и тот же тип - то вполне нормально запихнуть это в map с if-ом

один тип, только меняется значение свойста этого типа в зависимости от условия.

Ну все, должно работать. Проблема в твоем коде что ты возвращаещь Unit из map, и мутируешь item в мап

Ну все, должно работать. Проблема в твоем коде что ты возвращаещь Unit из map, и мутируешь item в мап

да, работает. Но выглядит как-то некрасиво, может есть какой-то более лаконичный синтаксис, чтобы не было if/else?

тут два вопроса про то как использовать okhttp с корутинами были, покажу как я использовал (cc @InsanusMokrassar @Vorkytaka) Для начала нам нужен адаптер для функции enqueue, который использует callback чтобы сделать suspend функцию: class OkHttpException( val request: Request, val exception: Exception ) : RuntimeException(exception) suspend fun Call.await(): Response = suspendCoroutine { cont: Continuation<Response> -> this.enqueue(object : Callback { override fun onResponse(call: Call, response: Response) { cont.resume(response) } override fun onFailure(call: Call, exception: IOException) { cont.resumeWithException(OkHttpException(call.request(), exception)) } }) } Далее нам нужно... Да в общем-то и все, теперь можно брать и использовать: val response = okHttpClient.newCall(request).await() И вот например задача Алексея: fun muchFun(request: Request): Response = runBlocking { okHttpClient.newCall(request).await() }

Спасибо, но что делать, если работа с OkHttp где-то внутри либы?

То есть есть класс, в котором происходит работа с OkHttp, там и происходит вызов send, блокирующий всё на свете, включая поток отправки/получения данных

А есть там же метод, работающий с enqueue

Т.е. у е тебя есть выбор какой метод в либе использовать? Либа предоставляет асинхронный API получается? Или в либе есть условно плохой код, и при этом ты не автор либы?

Т.е. у е тебя есть выбор какой метод в либе использовать? Либа предоставляет асинхронный API получается? Или в либе есть условно плохой код, и при этом ты не автор либы?

Давайте лучше скину

Сверху шляпа, которую могу вызывать я, снизу - то, что происходит в итоге

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

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

А, ну так все круто. У тебя есть асинхронный api, напиши функцию потипу той что я показал, она обернет send(req, call) и у тебя будет функция suspend send(req)

а можно конкретней?

https://github.com/InsanusMokrassar/AutoPostTelegramBot/blob/0.4.1/src/main/kotlin/com/github/insanusmokrassar/AutoPostTelegramBot/utils/extensions/TelegramBot.kt#L81

я пытался сделать так

но что-то вечно шло не так и отловить что именно у меня не получилось, но это не важно. Факт в том, что это не работает

я пытался сделать так

Тебя не настраживает сам факт что у тебя функция даже не suspend?

Тебя не настраживает сам факт что у тебя функция даже не suspend?

А должно?

я внутри оборачиваю всё в runBlocking

я помню, что runBlocking может сменить поток, если его уснуть

ой, нет. на многих уровнях не верно

ой, нет. на многих уровнях не верно

А именно?

зачем вообще делать runBlocking, если у тебя executeAsync не suspend.

там внизу join

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

потом вот такая цепочка колбеков https://github.com/InsanusMokrassar/AutoPostTelegramBot/blob/23866b3a3828aa1c843033477c26b514ac364607/src/main/kotlin/com/github/insanusmokrassar/AutoPostTelegramBot/plugins/base/commands/DeletePost.kt#L29

корутины как раз нужны чтобы от этого избавиться

корутины как раз нужны чтобы от этого избавиться

Да я-то понимаю

да, работает. Но выглядит как-то некрасиво, может есть какой-то более лаконичный синтаксис, чтобы не было if/else?

кстати, если ты меняешь только пропертю, но не сам обьект, не лучше ли foreach использовать?

но что мне делать вот с этим?:)

кстати, если ты меняешь только пропертю, но не сам обьект, не лучше ли foreach использовать?

хм, может быть)

но что мне делать вот с этим?:)

join-ом ты пытаешься я так понимаю timeout реализовать?

вообще вот эта конструкция с launch

join-ом ты пытаешься я так понимаю timeout реализовать?

Ну в классической Java это делается через wait и notify объекта, тут так делать нельзя, поэтому я создаю вечную корутину, которую отменяю и ловлю отмену в runBlocking

5 лет кодил на яве называется и ничего не знаю

Поэтому ключи immutable должны бытт

Ну в классической Java это делается через wait и notify объекта, тут так делать нельзя, поэтому я создаю вечную корутину, которую отменяю и ловлю отмену в runBlocking

так зачем этот launch? что он должен сделать

так зачем этот launch? что он должен сделать

Уведомление о том, что результат готов

с fuel никто не работал? у меня при вызове cancel() на загрузке файла ничего не происходит, дальше грузит

Уведомление о том, что результат готов

нет, так делать не нужно. очень плохо

ERROR: S client not available

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

нет, так делать не нужно. очень плохо

Да я понимаю

я и спрашиваю, как сделать хорошо

и как вообще это сделать работающим -.-

Всем привет. Взял в качестве di фрэймворка guice от гугла. Регистрирую мапперы в модуле примерно вот так bind<Mapper<Chat, domain.model.Chat>>().to<TelegramChatToChatMapper>() bind<Mapper<User?, domain.model.User>>().to<TelegramUserToUserMapper>() При создании контейнера ошибка что нет имплементации мапперов В качестве обертки над guice для котлина юзаю https://github.com/authzee/kotlin-guice это Никто не встречался с такой проблемой?

тут два вопроса про то как использовать okhttp с корутинами были, покажу как я использовал (cc @InsanusMokrassar @Vorkytaka) Для начала нам нужен адаптер для функции enqueue, который использует callback чтобы сделать suspend функцию: class OkHttpException( val request: Request, val exception: Exception ) : RuntimeException(exception) suspend fun Call.await(): Response = suspendCoroutine { cont: Continuation<Response> -> this.enqueue(object : Callback { override fun onResponse(call: Call, response: Response) { cont.resume(response) } override fun onFailure(call: Call, exception: IOException) { cont.resumeWithException(OkHttpException(call.request(), exception)) } }) } Далее нам нужно... Да в общем-то и все, теперь можно брать и использовать: val response = okHttpClient.newCall(request).await() И вот например задача Алексея: fun muchFun(request: Request): Response = runBlocking { okHttpClient.newCall(request).await() }

Примерно вот так

Примерно вот так

Так у меня нет доступа к Call

я могу только коллбэки прокинуть

и то, не в сам OkHttp, а в либу

я могу только коллбэки прокинуть

Этого и достаточно. Там вся фишка в suspendCoroutine и в том что ты дергаешь continuation в callbackах

Один метод написать и у тебя будут нормальные корутины в проекте

Пойду читать, что такое Continuation

@HeapyHop Правильно ли я понимаю, что suspendCoroutine блочит корутину пока на её объекте Continuation не вызовут resume[WithException]?

Да, все верно

хорошо, спасибо

я думал хэшкарты используют объект как ключ, а они походу хэш объекта юзают

а тебя не мучал вопрос, почему хэшмапы назвали ХЭШмапами?

потому что ключ значение?

Ребят, подскажите, есть ByteArray() с двумя элементами, как мне конвертнуть его в интовое число?

Зачем тебе Throw, ты же их джавы это не вызовишь

Зачем тебе Throw, ты же их джавы это не вызовишь

почему?

Да и даже если не вызову - лучше предупреждать, что может произойти

Сегодня день программиста

так что ребята

с праздником

Нада пить!

Ребята, подскажите как в toothpick + kotlin зарегистрировать дженерик класс?