A
Не ваш случай? https://youtu.be/w0kfnydnFWI
Похожая история. Вызов yield() в начале onEach помогает
Size: a a a
2019 December 19
AM
Похожая история. Вызов yield() в начале onEach помогает
ensureActive лучше yield, если вам действительно не нужно переключать контекст перед обработкой каждого элемента.A
ensureActive лучше yield, если вам действительно не нужно переключать контекст перед обработкой каждого элемента.Мне НЕ нужно переключать контекст, но ensureActive не работает.
VT
Мне НЕ нужно переключать контекст, но ensureActive не работает.
это либо баг, потому что и
yield, и ensureActive один и тот же механизм внутри используют, либо две нетривиально связанные через канал корутины на одном однопоточном диспатчереVT
было бы здорово, если бы вы self-contained репродьюсер в тикет закинули
A
было бы здорово, если бы вы self-contained репродьюсер в тикет закинули
Вот набрасал https://pl.kotl.in/RbhYc5_BO
A
Вот набрасал https://pl.kotl.in/RbhYc5_BO
Повторяемость не 100%, нужно позапускать пару раз
VT
это смешная проблема
VT
ensureActive резолвится в экстеншн на runBlocking %)VT
не самое очевидное поведение, конечно
VT
лечится явным выписыванием ресивера:
kotlin.coroutines.coroutineContext.ensureActive()A
ensureActive резолвится в экстеншн на runBlocking %)Спасибо
A
это смешная проблема
(где-то в далеке слышан смех Гарольда)
VT
я пытался это @DslMarker’ами полечить, но там к сожалению не сходится
KD
А чего в stdlib нет
flatMapIndexed? 🤔IS
А чего в stdlib нет
flatMapIndexed? 🤔а какой у вас кейс использования?
KD
а какой у вас кейс использования?
При flatMap'ингде мне нужно в новый элемент сохранять позицию из какого элемента оно создавалось.
AL
При flatMap'ингде мне нужно в новый элемент сохранять позицию из какого элемента оно создавалось.
Как обычно предположу, что юзкейсов было просто мало, для того, чтобы пихать в стдлибу. Но да, как обычно всегда можно написать у себя сбоку:
inline fun <T, R> Iterable<T>.flatMapIndexed(transform: (index: Int, T) -> Iterable<R>): List<R> {
return flatMapIndexedTo(ArrayList(), transform)
}
inline fun <T, R, C : MutableCollection<in R>> Iterable<T>.flatMapIndexedTo(destination: C, transform: (index: Int, T) -> Iterable<R>): C {
for ((index, element) in withIndex()) {
val list = transform(index, element)
destination.addAll(list)
}
return destination
}
listOf(4, 5, 5).flatMapIndexed { index, i -> listOf(index * index + index, i * i + i) }KD
Как обычно предположу, что юзкейсов было просто мало, для того, чтобы пихать в стдлибу. Но да, как обычно всегда можно написать у себя сбоку:
inline fun <T, R> Iterable<T>.flatMapIndexed(transform: (index: Int, T) -> Iterable<R>): List<R> {
return flatMapIndexedTo(ArrayList(), transform)
}
inline fun <T, R, C : MutableCollection<in R>> Iterable<T>.flatMapIndexedTo(destination: C, transform: (index: Int, T) -> Iterable<R>): C {
for ((index, element) in withIndex()) {
val list = transform(index, element)
destination.addAll(list)
}
return destination
}
listOf(4, 5, 5).flatMapIndexed { index, i -> listOf(index * index + index, i * i + i) }Да я уже написал, просто удивлён, что этого нет:)
VP
Как обычно предположу, что юзкейсов было просто мало, для того, чтобы пихать в стдлибу. Но да, как обычно всегда можно написать у себя сбоку:
inline fun <T, R> Iterable<T>.flatMapIndexed(transform: (index: Int, T) -> Iterable<R>): List<R> {
return flatMapIndexedTo(ArrayList(), transform)
}
inline fun <T, R, C : MutableCollection<in R>> Iterable<T>.flatMapIndexedTo(destination: C, transform: (index: Int, T) -> Iterable<R>): C {
for ((index, element) in withIndex()) {
val list = transform(index, element)
destination.addAll(list)
}
return destination
}
listOf(4, 5, 5).flatMapIndexed { index, i -> listOf(index * index + index, i * i + i) }А можно просто
mapIndexed(...).flatten()