mCounterEmitter = PublishSubject.create(); mCounterEmitter.subscribe(new Observer<Integer>() {

    @Override
    public void onCompleted() { }

    @Override
    public void onError(Throwable e) { }

    @Override
    public void onNext(Integer integer) {
        mCounterDisplay.setText(String.valueOf(integer));
    }
});