Gets coroutine version of ChangeStreamPublisher.
val <T : Any> ChangeStreamPublisher<T>.coroutine: CoroutineChangeStreamPublisher<T>