2

監視可能なオブジェクト (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 を使用する方法の例が見つかりませんでした。

4

1 に答える 1