Further simplification of collectValues.

Bug: 274159734
Test: N/A
Change-Id: Ida3fef1ae465f492241660af1d1518a1d0233496
This commit is contained in:
Alejandro Nijamkin
2023-03-27 08:52:49 -07:00
parent 546b4dbf32
commit f686be0b53

View File

@@ -69,10 +69,10 @@ fun <T> TestScope.collectValues(
flow: Flow<T>,
context: CoroutineContext = EmptyCoroutineContext,
start: CoroutineStart = CoroutineStart.DEFAULT,
): FlowValues<T> {
): FlowValue<List<T>> {
val values = mutableListOf<T>()
backgroundScope.launch(context, start) { flow.collect(values::add) }
return FlowValuesImpl {
return FlowValueImpl {
runCurrent()
values.toList()
}
@@ -83,17 +83,7 @@ interface FlowValue<T> : ReadOnlyProperty<Any?, T> {
operator fun invoke(): T
}
/** @see collectValues */
interface FlowValues<T> : ReadOnlyProperty<Any?, List<T>> {
operator fun invoke(): List<T>
}
private class FlowValueImpl<T>(private val block: () -> T) : FlowValue<T> {
override operator fun invoke(): T = block()
override fun getValue(thisRef: Any?, property: KProperty<*>): T = invoke()
}
private class FlowValuesImpl<T>(private val block: () -> List<T>) : FlowValues<T> {
override operator fun invoke(): List<T> = block()
override fun getValue(thisRef: Any?, property: KProperty<*>): List<T> = invoke()
}