Interface IKeyedOperationQueue
- Namespace
- Akavache
- Assembly
- Akavache.Core.dll
A queue that uses keys to determine the queue operations.
public interface IKeyedOperationQueue- Extension Methods
Methods
EnqueueObservableOperation<T>(string, Func<IObservable<T>>)
Queue an operation to run in the background that returns a stream of values. All operations with the same key will run in sequence, waiting for the previous operation to complete. If you want to queue an operation that already returns IObservable, this is your guy.
IObservable<T> EnqueueObservableOperation<T>(string key, Func<IObservable<T>> asyncCalculationFunc)Parameters
keystringThe key to use.
asyncCalculationFuncFunc<IObservable<T>>A method to run in the background that returns a stream of values.
Returns
- IObservable<T>
A future stream of values.
Type Parameters
TThe type of item to queue.
EnqueueOperation(string, Action)
Queue an operation to run in the background. All operations with the same key will run in sequence, waiting for the previous operation to complete.
IObservable<Unit> EnqueueOperation(string key, Action action)Parameters
Returns
- IObservable<Unit>
A future representing when the operation completes.
EnqueueOperation<T>(string, Func<T>)
Queue an operation to run in the background that returns a value. All operations with the same key will run in sequence, waiting for the previous operation to complete.
IObservable<T> EnqueueOperation<T>(string key, Func<T> calculationFunc)Parameters
keystringThe key to use.
calculationFuncFunc<T>A method to run in the background that returns a single value.
Returns
- IObservable<T>
A future value.
Type Parameters
TThe type of item to queue.
ShutdownQueue()
Flushes the remaining operations and returns a signal when they are all complete.
IObservable<Unit> ShutdownQueue()Returns
- IObservable<Unit>
An observable that signals when the queue has shutdown.