run

open override fun run(): Flow<T>(source)