collect

open suspend override fun collect(collector: FlowCollector<Pair<Long, Reserved<DestinationMessage>>>)