Method AutoRefreshObservableSynchronized
AutoRefreshObservableSynchronized<TObject, TKey, TAny>(IObservable<IChangeSet<TObject, TKey>>, Func<TObject, IObservable<TAny>>, TimeSpan?, IScheduler)
Automatically refresh downstream operator. The refresh is triggered when the observable receives a notification.
Declaration
public static IObservable<IChangeSet<TObject, TKey>> AutoRefreshObservableSynchronized<TObject, TKey, TAny>(this IObservable<IChangeSet<TObject, TKey>> source, Func<TObject, IObservable<TAny>> reevaluator, TimeSpan? changeSetBuffer = null, IScheduler scheduler = null) where TKey : notnull
Parameters
Type | Name | Description |
---|---|---|
IObservable<IChangeSet<TObject, TKey>> | source | The source observable change set. |
Func<TObject, IObservable<TAny>> | reevaluator | An observable which acts on items within the collection and produces a value when the item should be refreshed. |
TimeSpan? | changeSetBuffer | Batch up changes by specifying the buffer. This greatly increases performance when many elements require a refresh. |
IScheduler | scheduler | The scheduler. |
Returns
Type | Description |
---|---|
IObservable<IChangeSet<TObject, TKey>> | An observable change set with additional refresh changes. |
Type Parameters
Name | Description |
---|---|
TObject | The object of the change set. |
TKey | The key of the change set. |
TAny | The type of evaluation. |