Nikolay Lunyak
8ec248131d
The diagnostic target source element type was changed to prevent crash due to `checkPsiTypeConsistency()` in `duplicateParameterNameSimplified.fir.kt` ^KT-65584
42 lines
1.0 KiB
Kotlin
Vendored
42 lines
1.0 KiB
Kotlin
Vendored
// ISSUE: KT-65584
|
|
// WITH_STDLIB
|
|
|
|
fun interface Flow<out T> {
|
|
|
|
suspend fun collect(collector: FlowCollector<T>)
|
|
}
|
|
|
|
fun interface FlowCollector<in T> {
|
|
|
|
suspend fun emit(value: T)
|
|
}
|
|
|
|
inline fun <T, R> Flow<T>.flatMapLatest(crossinline transform: suspend (value: T) -> Flow<R>) = Flow { collector ->
|
|
collect { it1 -> transform(it1).collect { it2 -> collector.emit(it2) } }
|
|
}
|
|
|
|
fun <T> flowOf(value: T): Flow<T> = Flow { collector -> collector.emit(value) }
|
|
|
|
inline fun <T, R> Flow<T>.map(crossinline transform: suspend (value: T) -> R): Flow<R> = Flow { collector ->
|
|
collect { collector.emit(transform(it)) }
|
|
}
|
|
|
|
// ------
|
|
|
|
class StationId
|
|
class Playable
|
|
class Entity(val stationId: StationId)
|
|
class State(val playbackEntity: Entity)
|
|
|
|
internal suspend fun init(
|
|
queueState: State,
|
|
state: Flow<Playable>
|
|
) {
|
|
state
|
|
.flatMapLatest { playable ->
|
|
flowOf(playable).map { Triple(it, playable, queueState.playbackEntity.stationId) }
|
|
}
|
|
.collect { (likeState, playable, stationId) ->
|
|
}
|
|
}
|