collectSafely

open suspend override fun collectSafely(collector: FlowCollector<M>)