collectSafely

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

Accepts a collector and emits the cached values upfront and any subsequent value received by this ReplaySubject until the ReplaySubject gets terminated.