asStepFlow

fun <T> Flow<T>.asStepFlow(owner: IProducingStep<T>?): StepFlow<T>