Class MqttPacketBus

Namespace

MQTTnet.Internal

Assembly

MQTTnet.dll

public sealed class MqttPacketBus : IDisposable

Inheritance

object

MqttPacketBus

Implements

IDisposable

Inherited Members

object.GetType()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

MqttPacketBus()

public MqttPacketBus()

Properties

TotalItemsCount

public int TotalItemsCount { get; }

Property Value

int

Methods

Clear()

public void Clear()

DequeueItemAsync(CancellationToken)

public Task<MqttPacketBusItem> DequeueItemAsync(CancellationToken cancellationToken)

Parameters

cancellationToken CancellationToken

Returns

Task<MqttPacketBusItem>

Dispose()

public void Dispose()

DropFirstItem(MqttPacketBusPartition)

public MqttPacketBusItem DropFirstItem(MqttPacketBusPartition partition)

Parameters

partition MqttPacketBusPartition

Returns

MqttPacketBusItem

EnqueueItem(MqttPacketBusItem, MqttPacketBusPartition)

public void EnqueueItem(MqttPacketBusItem item, MqttPacketBusPartition partition)

Parameters

item MqttPacketBusItem

partition MqttPacketBusPartition

ExportPackets(MqttPacketBusPartition)

public List<MqttPacket> ExportPackets(MqttPacketBusPartition partition)

Parameters

partition MqttPacketBusPartition

Returns

List<MqttPacket>

ItemsCount(MqttPacketBusPartition)

public int ItemsCount(MqttPacketBusPartition partition)

Parameters

partition MqttPacketBusPartition

Returns

int

PartitionItemsCount(MqttPacketBusPartition)

public int PartitionItemsCount(MqttPacketBusPartition partition)

Parameters

partition MqttPacketBusPartition

Returns

int