Method WithExpirationTime
WithExpirationTime<T>(IObservable<T>, TimeSpan, Func<T, T>)
Allows to attach TTL to each value of the stream. If next value is not produced in expected time slice, fallback value is sent into stream as replacement until next value is propagated.
Declaration
public static IObservable<T> WithExpirationTime<T>(this IObservable<T> source, TimeSpan expirationTime, Func<T, T> fallbackValueSupplier)Parameters
| Type | Name | Description |
|---|---|---|
| IObservable<T> | source | |
| TimeSpan | expirationTime | |
| Func<T, T> | fallbackValueSupplier |
Returns
| Type | Description |
|---|---|
| IObservable<T> |
Type Parameters
| Name | Description |
|---|---|
| T |