Class BlockingCollectionTestActorQueue<T>
This class represents an implementation of ITestActorQueue<T>
that uses a ITestQueue<T> as its backing store.
Inherited Members
Namespace: Akka.TestKit.Internal
Assembly: Akka.TestKit.dll
Syntax
public class BlockingCollectionTestActorQueue<T> : ITestActorQueue<T>, ITestActorQueueProducer<T>
Type Parameters
Name | Description |
---|---|
T | The type of item to store. |
Constructors
| Improve this Doc View SourceBlockingCollectionTestActorQueue(ITestQueue<T>)
Initializes a new instance of the BlockingCollectionTestActorQueue<T> class.
Declaration
public BlockingCollectionTestActorQueue(ITestQueue<T> queue)
Parameters
Type | Name | Description |
---|---|---|
ITestQueue<T> | queue | The queue to use as the backing store. |
Methods
| Improve this Doc View SourceEnqueue(T)
Adds the specified item to the end of the queue.
Declaration
public void Enqueue(T item)
Parameters
Type | Name | Description |
---|---|---|
T | item | The item to add to the queue. |
GetAll()
Retrieves all items from the queue.
note
This will remove all items from the queue.
Declaration
public IEnumerable<T> GetAll()
Returns
Type | Description |
---|---|
IEnumerable<T> | An enumeration of all items removed from the queue. |
ToList()
Return an List<T> for the items inside the collection.
Declaration
public List<T> ToList()
Returns
Type | Description |
---|---|
List<T> | A List<T> for the BlockingCollectionTestActorQueue<T> items |