listen |
Listens change stream in an other thread. fun <T> ChangeStreamIterable<T>.listen(executor: ScheduledExecutorService = Executors.newSingleThreadScheduledExecutor(), delay: Long = 500, unit: TimeUnit = TimeUnit.MILLISECONDS, listener: (ChangeStreamDocument<T>) -> Unit): Unit |