rxjavaで遅延評価とデータアクセスを実現する

Question

###前提・実現したいこと
Android開発をしています．
実現したいことは，
・ある処理(仮にAとします)が成功すれば，秒数関係なくonComplete(仮にこの時の処理をB)を呼びたい
・ある処理が2秒未満に終わる場合には，2秒待機してonCompleteを呼びたい
・Errorの場合にはonErrorで良しなに処理をする
ということを実現できるStreamを作成したいのですが，待機されずにonCompleteが呼ばれてしまいます．

対処方法が検討つかずで，よろしければお力を貸していただきたいです．
よろしくお願いします．

###該当のソースコード

Observable.zip(A(), wait(2000), ((responseA, end) -> true)).subscribe(
                result -> {

                },
                (e) -> {},
                () -> B()
        );

private Observable<Boolean> wait(int millSec) {
      return Observable.create((Subscriber<? super Boolean> subscriber) -> {
            subscriber.onNext(true);
            subscriber.onCompleted();
            }).delay(millSec, TimeUnit.SECONDS);
}