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.