If you are looking for a bridge between an Rx Observable and flows, just use Observable.asFlow() extension.