flowOf

inline fun <T> Connection.flowOf(crossinline next: suspend Connection.() -> T): Flow<T>