Class ScalingPacketQueueHandler<T>

Inheritance
object
BasePacketQueueHandler<T>
ScalingPacketQueueHandler<T>
Implements
Inherited Members
Namespace: SlipeServer.Server.PacketHandling.Handlers.QueueHandlers
Assembly: SlipeServer.Server.dll
Syntax
public class ScalingPacketQueueHandler<T> : BasePacketQueueHandler<T>, IPacketQueueHandler<T>, IPacketQueueHandlerBase, IDisposable where T : Packet
Type Parameters
Name Description
T

Constructors

| Edit this page View Source

ScalingPacketQueueHandler(ILogger, IPacketHandler<T>)

Declaration
public ScalingPacketQueueHandler(ILogger logger, IPacketHandler<T> packetHandler)
Parameters
Type Name Description
ILogger logger
IPacketHandler<T> packetHandler
| Edit this page View Source

ScalingPacketQueueHandler(ILogger, IPacketHandler<T>, QueueHandlerScalingConfig?, int)

Declaration
public ScalingPacketQueueHandler(ILogger logger, IPacketHandler<T> packetHandler, QueueHandlerScalingConfig? config = null, int sleepTime = 10)
Parameters
Type Name Description
ILogger logger
IPacketHandler<T> packetHandler
QueueHandlerScalingConfig config
int sleepTime

Fields

| Edit this page View Source

pulseTaskCompletionSource

Declaration
protected TaskCompletionSource<int>? pulseTaskCompletionSource
Field Value
Type Description
TaskCompletionSource<int>

Methods

| Edit this page View Source

CheckWorkerCount()

Declaration
public void CheckWorkerCount()
| Edit this page View Source

Dispose()

Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.

Declaration
public override void Dispose()
Overrides
| Edit this page View Source

GetPulseTask()

Declaration
public Task GetPulseTask()
Returns
Type Description
Task

Implements