は、ラムダ式

Question

なしのJava 6で観察ReactiveXを作成します。私は、観察対象物（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を使用する方法の例を見つけることができませんでした。

Answer 1

あなたは何をしているのに対して正しいラムダレス構文を探していますか？

それは次のようになります。

static Observable<Integer> getDataSync(int i) { 
    return Observable.create(new Observable.OnSubscribe<Integer> { 
     @Override 
     public void call(Subscriber<? super Integer> s) { 
      // simulate latency 
      try { 
       Thread.sleep(1000); 
      } catch (Exception e) { 
       e.printStackTrace(); 
      } 
      s.onNext(i); 
      s.onCompleted(); 
     } 
    }); 
}