プログラマーの皆さん、こんにちは。
私は RxAndroid を使用して、ボタンが押されたときに 3 秒ごとにインターバル API 呼び出しを行っています。
private final CompositeDisposable disposables = new CompositeDisposable();
Observable fetchWeatherInterval = Observable.interval(3, TimeUnit.SECONDS)
.map(new Function<Long, String>() {
@Override
public String apply(Long aLong) throws Exception {
return getWeather("http://samples.openweathermap.org/data/2.5/weather?", "London,uk", "b1b15e88fa797225412429c1c50c122a1");
}
})
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread());
Observer displayWeatherInterval = new Observer<String>() {
@Override
public void onError(Throwable e) {
Log.e("Throwable ERROR", e.getMessage());
}
@Override
public void onComplete() {
}
@Override
public void onSubscribe(Disposable d) {
disposables.add(d);
}
@Override
public void onNext(String value) {
textViewWeatherInterval.append(value);
}
};
buttonFetchIntervalWeather.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View view) {
fetchWeatherInterval.subscribe(displayWeatherInterval);
}
});
私の質問は、ボタン (または onClick リスナー) を Observable にして他のものとチェーンする方法があるかどうかです。
buttonFetchIntervalWeather.subscribe(fetchWeatherInterval); のようなもの。
RxBinding を使用する
Subscription s = RxView.clicks(button)
.throttleFirst(5, TimeUnit.SECONDS) // maybe you want to ignore multiple clicks
.flatMap(foo -> fetchWeatherInterval)
.subscribe(displayWeatherInterval);
throttleFirst次の 5 秒間、さらにイベントを停止するだけなので、ユーザーがボタンを複数回クリックしても、次の 5 秒間は同じイベントfetchWeatherIntervalが再びトリガーされることはありません。
flatMapあるオブザーバブルの出力を別のオブザーバブルに、この場合はクリック イベントから に変換しますfetchWeatherInterval。詳細情報が必要な場合は、ドキュメントをお読みください。
また、RxJava2 も同様に機能します。RxJava1 については、これに回答しました。サブスクリプションを使い捨てに変更するだけです。
使用Observable.create():
Observable.create(new Action1<Emitter<View>>() {
@Override
public void call(Emitter<View> emitter) {
emitter.setCancellation(new Cancellable() {
@Override
public void cancel() throws Exception {
button.setOnClickListener(null);
emitter.onCompleted();
}
});
button.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
emitter.onNext(v);
}
});
}
}, Emitter.BackpressureMode.DROP);
またはラムダで:
Observable.create(emitter -> {
emitter.setCancellation(() -> {
button.setOnClickListener(null);
emitter.onCompleted();
});
button.setOnClickListener(emitter::onNext);
}, Emitter.BackpressureMode.DROP);
この記事はインターネットから収集されたものであり、転載の際にはソースを示してください。
侵害の場合は、連絡してください[email protected]
コメントを追加