fun <T> collectFromHere(flow: Flow<T>): Deferred<Flow<T>> {
    return GlobalScope.async {
        val channel = Channel<T>()
        flow.collect { channel.send(it) }
        channel.consumeAsFlow()
    }
}