Gets coroutine version of AggregatePublisher.
val <T : Any> AggregatePublisher<T>.coroutine: CoroutineAggregatePublisher<T>