6

私はクラスを持っていますProducer。単純化すると、このクラスを（RxJavapublic Object readData() ） として作成したいメソッドがあります。Observable

どのメソッドを呼び出す必要があるかを示す方法は? ProducerクラスをFutureorに変換する必要がありIterableますか?

次の問題は、 をn 秒ごとreadDataに呼び出す必要があることです。fromなどの一部のメソッドにはスケジューラーパラメーターがありますが、それを適用する方法の例が見つかりません。intervalメソッドを見つけましたが、整数のシーケンスを出力します。これまでのところ、Observable なしで使用していますExecutors.newSingleThreadScheduledExecutor().scheduleWithFixedDelay(....)

4

2 に答える 2

3

メソッドは引き続き使用できますが、interval()その結果は無視してください。

final Producer producer = ...;
int n = ...;
Observable<Object> obs = 
    Observable.interval(n,TimeUnit.SECONDS)
              .map(new Func1<Integer,Object>() {
                  @Override
                  public Object call(Integer i) {
                      return producer.readData();
                  }
               ));
于 2014-02-09T07:53:09.190 に答える