collectSafely

@FlowPreview()
open suspend override fun collectSafely(collector: FlowCollector<T>)

Start collecting signals from this PublishSubject.