public static Observable<Timestamped<Object>> createObservableFromSupplier(final Supplier<? extends Object> supplier, long rate, Scheduler scheduler){
        Observable<Long> interval = null;
        if(scheduler == null) {
            interval = Observable.interval(rate, TimeUnit.MILLISECONDS);
        } else {
            interval = Observable.interval(rate, TimeUnit.MILLISECONDS, scheduler);
        }

        return interval.takeUntil(exitSignal).map(new Func1<Long, Object>() {
            @Override
            public Object call(Long t1) {
                return supplier.get();
            }
        }).timestamp();
    }