process

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