티스토리 뷰

안드로이드

RxJava - delay

아카이sun 2016.06.25 11:42


RxJava Delay



Observable<String> myObservable = Observable.create(
new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
subscriber.onNext(
"text1");
subscriber.onNext("text2");
subscriber.onCompleted();
}
}
).delay(
2, TimeUnit.SECONDS, Schedulers.trampoline());
myObservable.subscribe(subScriber);



private Subscriber<String> subScriber = new Subscriber<String>() {
@Override
public void onCompleted() {
        Log.e("complete", "complete");

}

@Override
public void onError(Throwable e) {
Log.e("err", e.getMessage());
}

@Override
public void onNext(String s) {
Log.e("res", s);
}
};



result


06-25 02:40:43.655 12316-12316/com.akaisun.school E/time: 02:43
06-25 02:40:43.655 12316-12316/com.akaisun.school E/s: text1
06-25 02:40:45.655 12316-12316/com.akaisun.school E/time: 02:45
06-25 02:40:45.655 12316-12316/com.akaisun.school E/s: text2
06-25 02:40:47.655 12316-12316/com.akaisun.school E/complete: complete


댓글
댓글쓰기 폼