Rx Challenge #10: DistinctUntilChanged with expiration period


no comments

Rx Challenge #10: DistinctUntilChanged with expiration period

This challenge is DistinctUntilChanged  cancellation after a period.

When having event stream which may produce items in a row and then be idle for a period.

You may want to get item after a period even those it identical the the previous one.


On challenge you need to construct it using composition of existing Rx’s operators.

It can be formulate into the following pattern:

Code Snippet
  1. public static IObservable<T> DistinctUntilChanged<T>(
  2.     this IObservable<T> source,
  3.     TimeSpan distinctPeriod)
  4. {
  5.     // TODO: your code
  6. }


Rx, IObservable, IObserver, Task, Parallel, Async


All challenges available here.

Add comment
facebook linkedin twitter email

Leave a Reply

Your email address will not be published.

You may use these HTML tags and attributes: <a href="" title=""> <abbr title=""> <acronym title=""> <b> <blockquote cite=""> <cite> <code> <del datetime=""> <em> <i> <q cite=""> <s> <strike> <strong>