OnEveryDt[T] extends Observable[T]