public Observer<Timed<T>> timestamp() {
        dispatcher.append(new Dispatcher<Object>() {
            @Override
            public void onNext(final Object param) {
                if (downDispatcher != null) {
                    downDispatcher.onNext(Timed.of(param, System.currentTimeMillis()));
                }
            }
        });

        return (Observer<Timed<T>>) this;
    }
public Observer < Timed < T > > timestamp ( ) { dispatcher . append ( new Dispatcher < Object > ( ) { @ Override public void onNext ( final Object param ) { if ( downDispatcher != null ) { downDispatcher . onNext ( Timed . of ( param , System . currentTimeMillis ( ) ) ) ; } } } ) ; return ( Observer < Timed < T > > ) this ; }
@return this instance.
@see <a href="http://reactivex.io/RxJava/javadoc/io/reactivex/Observable.html#timestamp()">RxJava#timestamp</a>