byteArrayFlowFromSource

fun byteArrayFlowFromSource(coroutineContext: CoroutineContext = ioContext, sourceFactory: suspend () -> Source): Flow<ByteArray>