問題タブ [rx-kotlin]

Kotlin ラムダ構文に混乱しています。

最初に、私は持っています

これは正常に動作します。

次に、 onNext を実装する GroupRecyclerViewAdapter という別のクラスに移動しましたAction1<ArrayList<Group>>。

ただし、エラーが発生しました：

次のように変更することでエラーを修正できます。

型を指定せずにラムダを書く方法はありますか? ( Action1<kotlin.Throwable>, Action0)

注: subscribe は RxJava メソッドです

編集 1

ファイル名を返す関数を作成しましたが、Observable<String>このメソッドを呼び出したサブスクリプションでイベントが発生しません。また、onError、またはonCompleteの呼び出しはありません
私のコードを参照してください：

すべてがgetAllFiles()関数で呼び出されていますが、何が欠けていますか?

Android アプリで rxAndroid と rxKotlin を使用して、ネットワーク リクエストを非同期的に処理しています。Snackbar ボタンをクリックした後にのみ、失敗したネットワーク要求を再試行したいと思います。

私のコードは今：

レトロフィットのための都市インターフェース:

API ファクトリー:

そのような方法でオブザーバブルを再起動するにはどうすればよいですか?

これが多くの Rx ルールに違反していることはわかっていますが、私はRxJava-JDBCが本当に好きで、チームメイトもそうしています。リレーショナル データベースは私たちの活動の中核であり、Rx も同様です。

ただし、として出力するのObservable<ResultSet>ではなく、プルベースの Java 8Stream<ResultSet>または Kotlinだけを使用したい場合がありSequence<ResultSet>ます。しかし、RxJava-JDBC ライブラリーはObservable<ResultSet>.

Observable<ResultSet>したがって、拡張関数を使用して を に変換し、中間のコレクションや呼び出しSequence<ResultSet>を行わない方法があるかどうか疑問に思っています。toBlocking()以下はこれまでのところすべてですが、プッシュおよびプルベースのシステムに接続しようとして頭が回転しています。呼び出しResultSetごとにステートフルであるため、どちらもバッファリングできません。onNext()これは不可能な作業ですか？