,System.Func{System.IObservable{--0}})} })} })}
OperationQueue.EnqueueObservableOperation(int, string, IObservable, Func>) method¶
Defined in
Type: OperationQueue
Namespace: Punchclock.Reactive
Assembly: Punchclock.Reactive.dll
Applies to
net10.0, net10.0-browserwasm1.0, net10.0-desktop1.0, net9.0, net9.0-browserwasm1.0, net9.0-desktop1.0, net8.0, net8.0-ios17.5, net8.0-maccatalyst17.5, net8.0-macos14.2, net8.0-macos14.5, net8.0-tvos17.2, netstandard2.1, net462, net481
Overloads¶
- 1.
public IObservable<T> EnqueueObservableOperation<T, TDontCare>(int priority, string key, IObservable<TDontCare> cancel, Func<IObservable<T>> asyncCalculationFunc) - 2.
public IObservable<T> EnqueueObservableOperation<T>(int priority, string key, Func<IObservable<T>> asyncCalculationFunc) - 3.
public IObservable<T> EnqueueObservableOperation<T>(int priority, Func<IObservable<T>> asyncCalculationFunc)
1. Overload¶
public IObservable<T> EnqueueObservableOperation<T, TDontCare>(int priority, string key, IObservable<TDontCare> cancel, Func<IObservable<T>> asyncCalculationFunc)
Summary: This method enqueues an action to be run at a later time, according to the scheduling policies (i.e. via priority and key).
Type parameters
| Name | Description |
|---|---|
T | The type of item for the observable. |
TDontCare | Type parameter used to allow any observable type for cancellation signal. |
Parameters
| Name | Type | Description |
|---|---|---|
priority | int | The priority of operation. Higher priorities run before lower ones. |
key | string | A key to apply to the operation. Items with the same key will be run in order. Pass null or DefaultKey for non-keyed operations. |
cancel | IObservable | An observable which if signalled, the operation will be cancelled. |
asyncCalculationFunc | Func | The async method to execute when scheduled. |
Returns: IObservable
2. Overload¶
public IObservable<T> EnqueueObservableOperation<T>(int priority, string key, Func<IObservable<T>> asyncCalculationFunc)
Summary: This method enqueues an action to be run at a later time, according to the scheduling policies (i.e. via priority and key).
Type parameters
| Name | Description |
|---|---|
T | The type of item for the observable. |
Parameters
| Name | Type | Description |
|---|---|---|
priority | int | Higher priorities run before lower ones. |
key | string | Items with the same key will be run in order. Pass null or DefaultKey for non-keyed operations. |
asyncCalculationFunc | Func | The async method to execute when scheduled. |
Returns: IObservable
3. Overload¶
public IObservable<T> EnqueueObservableOperation<T>(int priority, Func<IObservable<T>> asyncCalculationFunc)
Summary: This method enqueues an action to be run at a later time, according to the scheduling policies (i.e. via priority).
Type parameters
| Name | Description |
|---|---|
T | The type of item for the observable. |
Parameters
| Name | Type | Description |
|---|---|---|
priority | int | Higher priorities run before lower ones. |
asyncCalculationFunc | Func | The async method to execute when scheduled. |
Returns: IObservable