rx-java - オブザーバブルのフラット化オブザーバブル

Question

私がやりたいことは、毎秒別の関数を実行する関数を作成することです。2番目の関数が戻り、最初の関数も代わりにObservables<A>戻りたいObservables<A>Observable<Observable<A>>

例えば：

private A calcA(){
   ...
   return new A(...)
}

public Observable<A> getAs(){
   return Observable.create( subscriber -> {
      Bool condition = ...
      do {
         subscriber.onNext(calcA())
      } while (condition)
      subscriber.onComplete()
   })
}

public Observable<A> pollAs(){
   return Observable.create(subscriber -> {
      do {
         subscriber.onNext(getAs()) // Flatten here I guess
         Thread.sleep(1000)
      } while(true)
   })

だから私は似たようなことをしたいと思います（これをJavaっぽい方法で書き込もうとしましたが、Kotlinを使用します）