Class BlockingQueue<TItem>

Namespace

MQTTnet.Internal

Assembly

MQTTnet.dll

public sealed class BlockingQueue<TItem> : IDisposable

Type Parameters

TItem

Inheritance

object

BlockingQueue<TItem>

Implements

IDisposable

Inherited Members

object.GetType()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

BlockingQueue()

public BlockingQueue()

Properties

Count

public int Count { get; }

Property Value

int

Methods

Clear()

public void Clear()

Dequeue(CancellationToken)

public TItem Dequeue(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken

Returns

TItem

Dispose()

public void Dispose()

Enqueue(TItem)

public void Enqueue(TItem item)

Parameters

item TItem

PeekAndWait(CancellationToken)

public TItem PeekAndWait(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken

Returns

TItem

RemoveFirst()

public TItem RemoveFirst()

Returns

TItem

RemoveFirst(Predicate<TItem>)

public void RemoveFirst(Predicate<TItem> match)

Parameters

match Predicate<TItem>