java - RxJava 订阅时类型不匹配

Question

我有以下代码来获取滑动窗口平均值。我在订阅函数中收到类型不匹配错误。我正在尝试使用 RxMath 平均函数获取 cpu 使用率的平均值。

import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

import rx.*;
import rx.Observable;
import rx.functions.Action1;
import rx.functions.Func1;
import rx.observables.MathObservable;

public class stack {
    private ScheduledThreadPoolExecutor executorPool;

    public void test() {
        Double tests = (double) 100;

        Observable myObservable = Observable.interval(1000, TimeUnit.MILLISECONDS)
                .map(new Func1<Long, Double>() {
                    @Override
                    public Double call(Long aLong) {
                        Double d = (double) 100;//calculate CPU usage                             
                        return d;
                    }
                })
                .window(1, TimeUnit.SECONDS)
                .flatMap(new Func1<Observable<Double>, Observable<Double>>() {
                    @Override
                    public Observable<Double> call(Observable<Double> windowObservable) {
                        return MathObservable.averageDouble(windowObservable);
                    }
                })
                .subscribe(new Action1<Double>() {
                    public void call(Double s) {
                        System.out.println(s);
                    }
                });
    }
}

Answer 1

只需从开头删除 Observable myObservable = 即可。

subscribe 返回的是 Subscription，而不是 Observable。就您而言，您不需要记住对 Observable 的引用。

如果您这样做，请遵循以下模式:

Observable<Double> myObservable = stuffThatReturnsAnObservable();
Subscription subscription = myObservable.subscribe();