問題タブ [rx-kotlin]

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

例えば：

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

私はこの問題で立ち往生しています。これはかなり単純なはずです。Maybeが として完了したときにコード ブロックを実行するには、サブスクライバーが必要Empty Maybeです。見つけた

1. デフォルトの Maybe 値を渡すことも、switchIfEmpty を使用することもできますが、どちらもハッキーだと思います。
2. また、onComplete 関数を (他の 2 つのイベントのハンドラーと共に) 受け取る subscribe 関数がありますが、onComplete は、空の完了かどうかを調べるために使用できる引数を取りません。
3. 別の方法は かもしれませんがMaybe.isEmpty.blockingGet()、それも汚れています。

私は次のことを試しました( Kotlin Syntax ):-

しかし、予想どおり、サブスクリプションを 2 回実行しており、ここでテストしています:-

誰かがこれを解決するためのより良い方法を提案してもらえますか?

申し訳ありませんがnooby kotlinの質問

void のオブザーバブルを返すにはどうすればよいですか? 私は、、試してみvoidましVoid()たVoid