IO
все равно у нее исчезающе мало юзкейсов
Size: a a a
2020 May 21
AN
а смысл её убирать?
Некузявая.
IO
дань уважения C#
AN
A|B красивее. Не знаю, насколько оно совместимо
IO
A|B красивее. Не знаю, насколько оно совместимо
у меня ощущение, будто вы какой-то юнион-тип написали
AN
у меня ощущение, будто вы какой-то юнион-тип написали
юнион A&B
IO
в цейлоне (also known as несостоявшийся котлин), кстати, юнионы так и выглядят
AN
в цейлоне (also known as несостоявшийся котлин), кстати, юнионы так и выглядят
А, может я попутал. Момент
AL
юнион A&B
Всё наоборот, да :)
AN
да, точно, в скале юнионы тожк через черточку. Ну значит наоборот. Пересечение через &
IO
я смог найти у себя в коде
whereIK
Коллеги, а можете пожалуйста подсказать, как будет выглядеть аналогичный код на корутинах?
Вроде бы под это подходят actors, но у меня к ним возникает тот же самый вопрос что и к MVal в arrow – почему можно только в соответствующем scope, это же... странно? Выполняться будет в контексте, в котором мы вызываем put/send, зачем создавать эту штуку внутри контекста
https://gist.github.com/ivkomarov/eb9e8feae7a7a4eb4bbd7115a898b148
Вроде бы под это подходят actors, но у меня к ним возникает тот же самый вопрос что и к MVal в arrow – почему можно только в соответствующем scope, это же... странно? Выполняться будет в контексте, в котором мы вызываем put/send, зачем создавать эту штуку внутри контекста
https://gist.github.com/ivkomarov/eb9e8feae7a7a4eb4bbd7115a898b148
Никто так и не ответил :C
Подскажите пожалуйста хотя-бы в сторону каких компонентов из kotlinx-coroutines смотреть.
Подскажите пожалуйста хотя-бы в сторону каких компонентов из kotlinx-coroutines смотреть.
I
Никто так и не ответил :C
Подскажите пожалуйста хотя-бы в сторону каких компонентов из kotlinx-coroutines смотреть.
Подскажите пожалуйста хотя-бы в сторону каких компонентов из kotlinx-coroutines смотреть.
а так ли важен порядок?
IK
Да, порядок крайне критичен. Практически всегда присутствует backpressure, и важно, чтобы "залежавшиеся" сообщения первыми пытались отправиться
IK
Итоговое решение должно гарантировать приоритет для сообщений, которые не были доставлены дольше всего.
AN
Никто так и не ответил :C
Подскажите пожалуйста хотя-бы в сторону каких компонентов из kotlinx-coroutines смотреть.
Подскажите пожалуйста хотя-бы в сторону каких компонентов из kotlinx-coroutines смотреть.
я уже на диване валялся, код было читать не удобно, сейчас посмотрю
AN
Никто так и не ответил :C
Подскажите пожалуйста хотя-бы в сторону каких компонентов из kotlinx-coroutines смотреть.
Подскажите пожалуйста хотя-бы в сторону каких компонентов из kotlinx-coroutines смотреть.
А можно в двух словах, что нужно? Судя по всему вам годится обычный flow, он будет FIFO. Или надо переставлять порядок вычислений.
IK
А можно в двух словах, что нужно? Судя по всему вам годится обычный flow, он будет FIFO. Или надо переставлять порядок вычислений.
Я отправляю сообщения в Discord из очереди на отправку. При статусе 429, мне нужно положить сообщение в очередь на отправку, и при этом, чем более старым является сообщение, тем раньше оно должно попытаться отправиться снова (тем ближе оно к началу очереди). Подобный механизм позволит гарантировать доставку сообщений.
AN
Я отправляю сообщения в Discord из очереди на отправку. При статусе 429, мне нужно положить сообщение в очередь на отправку, и при этом, чем более старым является сообщение, тем раньше оно должно попытаться отправиться снова (тем ближе оно к началу очереди). Подобный механизм позволит гарантировать доставку сообщений.
Если я правильно понял, то вам достаточно сделать обычный Flow, но суспендить отправку при получении статуса