Class BlockingQueue<T>
This class represents a queue with the same characteristics of a BlockingCollection<T>.
The queue can enqueue items at either the front (FIFO) or the end (LIFO) of the collection.
Note! Part of internal API. Breaking changes may occur without notice. Use at own risk.
Inheritance
BlockingQueue<T>
Assembly: Akka.TestKit.dll
Syntax
public class BlockingQueue<T> : ITestQueue<T>
Type Parameters
Name |
Description |
T |
The type of item to store.
|
Properties
|
Improve this Doc
View Source
Count
Declaration
public int Count { get; }
Property Value
Methods
|
Improve this Doc
View Source
AddFirst(T)
Declaration
[Obsolete("This method will be removed from the public API in the future")]
public void AddFirst(T item)
Parameters
Type |
Name |
Description |
T |
item |
|
|
Improve this Doc
View Source
Enqueue(T)
Declaration
public void Enqueue(T item)
Parameters
Type |
Name |
Description |
T |
item |
|
|
Improve this Doc
View Source
EnqueueAsync(T)
Declaration
public ValueTask EnqueueAsync(T item)
Parameters
Type |
Name |
Description |
T |
item |
|
Returns
Type |
Description |
System.Threading.Tasks.ValueTask |
|
|
Improve this Doc
View Source
Peek(CancellationToken)
Declaration
public T Peek(CancellationToken cancellationToken)
Parameters
Returns
|
Improve this Doc
View Source
PeekAsync(CancellationToken)
Declaration
public ValueTask<T> PeekAsync(CancellationToken cancellationToken)
Parameters
Returns
Type |
Description |
System.Threading.Tasks.ValueTask<T> |
|
|
Improve this Doc
View Source
Take(CancellationToken)
Declaration
public T Take(CancellationToken cancellationToken)
Parameters
Returns
|
Improve this Doc
View Source
TakeAsync(CancellationToken)
Declaration
public ValueTask<T> TakeAsync(CancellationToken cancellationToken)
Parameters
Returns
Type |
Description |
System.Threading.Tasks.ValueTask<T> |
|
|
Improve this Doc
View Source
ToList()
Declaration
Returns
|
Improve this Doc
View Source
TryEnqueue(T, Int32, CancellationToken)
Declaration
public bool TryEnqueue(T item, int millisecondsTimeout, CancellationToken cancellationToken)
Parameters
Returns
|
Improve this Doc
View Source
TryEnqueueAsync(T, Int32, CancellationToken)
Declaration
public ValueTask<bool> TryEnqueueAsync(T item, int millisecondsTimeout, CancellationToken cancellationToken)
Parameters
Returns
Type |
Description |
System.Threading.Tasks.ValueTask<Boolean> |
|
|
Improve this Doc
View Source
TryPeek(out T)
Declaration
public bool TryPeek(out T item)
Parameters
Type |
Name |
Description |
T |
item |
|
Returns
|
Improve this Doc
View Source
TryPeek(out T, Int32, CancellationToken)
Declaration
public bool TryPeek(out T item, int millisecondsTimeout, CancellationToken cancellationToken)
Parameters
Returns
|
Improve this Doc
View Source
TryPeekAsync(Int32, CancellationToken)
Declaration
public ValueTask<(bool success, T item)> TryPeekAsync(int millisecondsTimeout, CancellationToken cancellationToken)
Parameters
Returns
Type |
Description |
System.Threading.Tasks.ValueTask<System.ValueTuple<Boolean, T>> |
|
|
Improve this Doc
View Source
TryPeekAsync(CancellationToken)
Declaration
public ValueTask<(bool success, T item)> TryPeekAsync(CancellationToken cancellationToken)
Parameters
Returns
Type |
Description |
System.Threading.Tasks.ValueTask<System.ValueTuple<Boolean, T>> |
|
|
Improve this Doc
View Source
TryTake(out T, Int32, CancellationToken)
Declaration
public bool TryTake(out T item, int millisecondsTimeout, CancellationToken cancellationToken)
Parameters
Returns
|
Improve this Doc
View Source
TryTake(out T, CancellationToken)
Declaration
public bool TryTake(out T item, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Returns
|
Improve this Doc
View Source
TryTakeAsync(Int32, CancellationToken)
Declaration
public ValueTask<(bool success, T item)> TryTakeAsync(int millisecondsTimeout, CancellationToken cancellationToken)
Parameters
Returns
Type |
Description |
System.Threading.Tasks.ValueTask<System.ValueTuple<Boolean, T>> |
|
|
Improve this Doc
View Source
TryTakeAsync(CancellationToken)
Declaration
public ValueTask<(bool success, T item)> TryTakeAsync(CancellationToken cancellationToken)
Parameters
Returns
Type |
Description |
System.Threading.Tasks.ValueTask<System.ValueTuple<Boolean, T>> |
|
Implements
Extension Methods