process

abstract val process: (Flow<A>, Job) -> Unit