Package com.mewna.catnip.util.task

Class GatewayTask<T>

java.lang.Object

com.mewna.catnip.util.task.QueueTask<T>

com.mewna.catnip.util.task.GatewayTask<T>

public class GatewayTask<T>
extends QueueTask<T>

Field Summary

Fields inherited from class com.mewna.catnip.util.task.QueueTask

action, queue

Constructor Summary

Constructors

Constructor	Description
GatewayTask(Queue<T> queue, Consumer<T> action, Catnip catnip, String id, long periodMs, long limit)

Method Summary

Modifier and Type	Method	Description
static GatewayTask<PresenceImpl>	gatewayPresenceTask(Catnip catnip, String id, Consumer<PresenceImpl> action)
static GatewayTask<com.grack.nanojson.JsonObject>	gatewaySendTask(Catnip catnip, String id, Consumer<com.grack.nanojson.JsonObject> action)
void	run()
void	shutdown()

Methods inherited from class com.mewna.catnip.util.task.QueueTask

isEmpty, offer, peek, queue, size

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

GatewayTask

public GatewayTask(@Nonnull
 Queue<T> queue,
 @Nonnull
 Consumer<T> action,
 @Nonnull
 Catnip catnip,
 String id,
 long periodMs,
 long limit)

Method Details

gatewaySendTask

public static GatewayTask<com.grack.nanojson.JsonObject> gatewaySendTask(@Nonnull
 Catnip catnip,
 @Nonnull
 String id,
 @Nonnull
 Consumer<com.grack.nanojson.JsonObject> action)

gatewayPresenceTask

public static GatewayTask<PresenceImpl> gatewayPresenceTask(@Nonnull
 Catnip catnip,
 @Nonnull
 String id,
 @Nonnull
 Consumer<PresenceImpl> action)

shutdown

public void shutdown()

run

public void run()

Specified by:

run in class QueueTask<T>