org.litote.kmongo

Class ChangeStreamIterablesKt

org.litote.kmongo.ChangeStreamIterablesKt

public class ChangeStreamIterablesKt

Constructor Detail

ChangeStreamIterablesKt

public ChangeStreamIterablesKt()

Method Detail

listen

public static <T> void listen(@NotNull
                              com.mongodb.client.ChangeStreamIterable<T> $this$listen,
                              @NotNull
                              java.util.concurrent.ScheduledExecutorService executor,
                              long delay,
                              @NotNull
                              java.util.concurrent.TimeUnit unit,
                              @NotNull
                              kotlin.jvm.functions.Function1<? super com.mongodb.client.model.changestream.ChangeStreamDocument<T>,kotlin.Unit> listener)

Listens change stream in an other thread.

Parameters:

executor - the executor service for the thread instantiation - default is Executors.newSingleThreadExecutor

delay - the delay the executor is waiting before submitting the task

unit - the unit of the delay

listener - to listen changes