|
Lean
$LEAN_TAG$
|
Interface used to handle items being processed and communicate busy state More...
Public Member Functions | |
| void | Add (T item) |
| Adds the items to this collection More... | |
| void | Add (T item, CancellationToken cancellationToken) |
| Adds the items to this collection More... | |
| void | CompleteAdding () |
| Marks the collection as not accepting any more additions More... | |
| IEnumerable< T > | GetConsumingEnumerable () |
| Provides a consuming enumerable for items in this collection. More... | |
| IEnumerable< T > | GetConsumingEnumerable (CancellationToken cancellationToken) |
| Provides a consuming enumerable for items in this collection. More... | |
Properties | |
| WaitHandle | WaitHandle [get] |
| Gets a wait handle that can be used to wait until this instance is done processing all of it's item More... | |
| int | Count [get] |
| Gets the number of items held within this collection More... | |
| bool | IsBusy [get] |
| Returns true if processing, false otherwise More... | |
Interface used to handle items being processed and communicate busy state
| T | The item type being processed |
Definition at line 27 of file IBusyCollection.cs.
| void QuantConnect.Interfaces.IBusyCollection< T >.Add | ( | T | item | ) |
Adds the items to this collection
| item | The item to be added |
Implemented in QuantConnect.Util.BusyBlockingCollection< T >, and QuantConnect.Util.BusyCollection< T >.
| void QuantConnect.Interfaces.IBusyCollection< T >.Add | ( | T | item, |
| CancellationToken | cancellationToken | ||
| ) |
Adds the items to this collection
| item | The item to be added |
| cancellationToken | A cancellation token to observer |
Implemented in QuantConnect.Util.BusyBlockingCollection< T >, and QuantConnect.Util.BusyCollection< T >.
| void QuantConnect.Interfaces.IBusyCollection< T >.CompleteAdding | ( | ) |
Marks the collection as not accepting any more additions
Implemented in QuantConnect.Util.BusyCollection< T >, and QuantConnect.Util.BusyBlockingCollection< T >.
| IEnumerable<T> QuantConnect.Interfaces.IBusyCollection< T >.GetConsumingEnumerable | ( | ) |
Provides a consuming enumerable for items in this collection.
Implemented in QuantConnect.Util.BusyBlockingCollection< T >, and QuantConnect.Util.BusyCollection< T >.
| IEnumerable<T> QuantConnect.Interfaces.IBusyCollection< T >.GetConsumingEnumerable | ( | CancellationToken | cancellationToken | ) |
Provides a consuming enumerable for items in this collection.
| cancellationToken | A cancellation token to observer |
Implemented in QuantConnect.Util.BusyBlockingCollection< T >, and QuantConnect.Util.BusyCollection< T >.
|
get |
Gets a wait handle that can be used to wait until this instance is done processing all of it's item
Definition at line 33 of file IBusyCollection.cs.
|
get |
Gets the number of items held within this collection
Definition at line 38 of file IBusyCollection.cs.
|
get |
Returns true if processing, false otherwise
Definition at line 43 of file IBusyCollection.cs.