監視可能なオブジェクト (ReactiveX) を作成する方法の例を見つけました。
static Observable<Integer> getDataSync(int i) {
return Observable.create((Subscriber<? super Integer> s) -> {
// simulate latency
try {
Thread.sleep(1000);
} catch (Exception e) {
e.printStackTrace();
}
s.onNext(i);
s.onCompleted();
});
}
しかし、私のプロジェクトはラムダ式の Java 8 をサポートしていません。ラムダ式なしで ReactiveX observable を使用する方法の例が見つかりませんでした。