TopicQueue<'Topic, 'T>
Namespace: MBrace.Thespian.Runtime
Immutable queue implementation with messages indexable by topic
Record Fields
| Record Field | Description |
GlobalQueue
Signature: ImmutableQueue<'T>
|
|
TopicQueues
Signature: Map<'Topic,ImmutableQueue<'T>>
|
Instance members
| Instance member | Description |
Cleanup(cleanup)
Signature: (cleanup:('Topic -> bool)) -> 'T [] * TopicQueue<'Topic,'T>
|
Perform cleanup of the queue, by moving all elements from cleaned up topics to the global queue. |
Enqueue(t, topic)
Signature: (t:'T * topic:'Topic option) -> TopicQueue<'Topic,'T>
|
Enqueue a new item to queue, optionally with a specified topic. |
TryDequeue(topic)
Signature: (topic:'Topic option) -> ('T * TopicQueue<'Topic,'T>) option
|
Dequeue a message from queue, optionally declaring a topic. |
Static members
| Static member | Description |
Empty
Signature: TopicQueue<'Topic,'T>
|
Creates an empty queue CompiledName: |
