ai.tock.bot.connector

Class ConnectorQueue

ai.tock.bot.connector.ConnectorQueue

public class ConnectorQueue

A Queue to ensure the calls from the same user id are sent sequentially.

Constructor Detail

ConnectorQueue

public ConnectorQueue(@NotNull
                      ai.tock.shared.Executor executor)

A Queue to ensure the calls from the same user id are sent sequentially.

Method Detail

add

public void add(@NotNull
                Action action,
                long delayInMs,
                @NotNull
                kotlin.jvm.functions.Function1<? super ai.tock.bot.engine.action.Action,kotlin.Unit> send)

Adds an action to send to a queue by recipient.

This method is thread safe.

Parameters:

action - the action to send

delayInMs - the optional delay

send - the send function