kmongo / org.litote.kmongo / com.mongodb.client.ChangeStreamIterable

Extensions for com.mongodb.client.ChangeStreamIterable

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