gistfile1.txt

// 1: do func1(); which returns an Observable<Res1>
// 2: once Res1 is onComplete (so done without error):
//    3a: do func2();
//    3b: as long as the result does not match a given codition.
// 4: if done, return the original result from func1

In sync it would more or less look like:

Res1 res1 = func1();
done = false;
while(!done) {
  if (func2() == condition) {
    done = true;
  }
}

... for more context: I store a document on the server and then need to poll the server for its state (replicated, persisted).. and once my needed state is satisfied I just return whatever got returned from the original store call.

return res1;

Yup, that looks good.

object MainScala {
  def main(args: Array[String]): Unit = {
    def upsert(i: Int) = {
      println(s"upsert($i)")
      Observable.items(i)
    }

    var i = 0;
    def send() = {
      val result = AsyncSubject[Int]();
      Observable[Int](observer => {
        println(s"calling send() with $i")
        observer.onNext(i)
        i += 1
        observer.onCompleted()
      }).subscribe(result)
      result
    }
    def test(n: Int) = n < 5
    val zs = upsert(1).flatMap(x =>
      Observable.defer{ send() }.repeat.dropWhile(n => test(n))
        .take(1).map(_ => x)
    )
    zs.subscribe(z => println(z))
    readLine()
  }
}