###前提・実現したいこと
Android開発をしています.
実現したいことは,
・ある処理(仮にAとします)が成功すれば,秒数関係なくonComplete(仮にこの時の処理をB)を呼びたい
・ある処理が2秒未満に終わる場合には,2秒待機してonCompleteを呼びたい
・Errorの場合にはonErrorで良しなに処理をする
ということを実現できるStreamを作成したいのですが,待機されずにonCompleteが呼ばれてしまいます.
対処方法が検討つかずで,よろしければお力を貸していただきたいです.
よろしくお願いします.
###該当のソースコード
Java
1 2Observable.zip(A(), wait(2000), ((responseA, end) -> true)).subscribe( 3 result -> { 4 5 }, 6 (e) -> {}, 7 () -> B() 8 ); 9 10private Observable<Boolean> wait(int millSec) { 11 return Observable.create((Subscriber<? super Boolean> subscriber) -> { 12 subscriber.onNext(true); 13 subscriber.onCompleted(); 14 }).delay(millSec, TimeUnit.SECONDS); 15}
あなたの回答
tips
プレビュー