rxjava timer subscribe NOT long类型

Question

RXJava定时器returns订阅，其中Action1使用Long类型。我需要另一个来传递另一种类型的 Action1 对象。

Observable<Long> observable = Observable.timer(7, TimeUnit.SECONDS, Schedulers.computation());
cancelOrderSubscription = observable
    .subscribeOn(Schedulers.computation())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(new Action1<Long>() {
        @Override
        public void call(Long aLong) {
            // NOT LONG REQUIRED
        }
    });

Answer 1

基于 akarnokd 评论。

Observable.timer(5, TimeUnit.SECONDS)
        .observeOn(AndroidSchedulers.mainThread())
        .map(new Func1<Long, MyOrderStorageItem>() {
            @Override
            public MyOrderStorageItem call(Long aLong) {
                return myOrderStorageItem;
            }
        })
        .subscribe(new Action1<MyOrderStorageItem>() {
            @Override
            public void call(MyOrderStorageItem myOrderStorageItem) {
                // use object myOrderStorageItem
            }
        });

rxjava timer subscribe NOT long类型

rxjava timer subscribe NOT long type

rx-java

rx-android