問題タブ [kotlinx.coroutines.flow]

にアイテムを送信/送信する方法を知りたかったKotlin.Flowので、私のユースケースは次のとおりです。

consumer/ViewModel/Presenter では、次の 関数でサブスクライブできます。collect

しかし、問題はRepository脇にあります。RxJava では、Behaviorsubjectを使用してそれを として公開し、次のObservable/Flowableような新しいアイテムを発行できます。

しかし、新しいフローを構築するたびに:

集めるしかない。値をフローに送信するにはどうすればよいですか?

Kotlin フローに慣れ始めたばかりです。

このために、それらを使用して、次のフローを使用してシミュレートするバイナリ ファイルの内容を解析しています。

さて、基本的にさまざまな情報セットを抽出するために、ファイルの内容を複数回必要とします。ただし、ファイルを 2 回読み取るのではなく、1 回だけ読み取ります。

フローを複製/複製する組み込みのメカニズムがないように見えるため、次のヘルパー関数を開発しました。

次に、これを次のように使用します (ファイルとの類推について考えてください: フローaはすべてのレコードを取得bし、最初の 3 つのレコード (="ファイル ヘッダー") のみをフローcし、ヘッダーの後にすべてをフローします):

出力：

これまでのところ良さそうです。ただし、この点で Kotlin のフローを正しく使用しているかどうかはわかりません。
デッドロックや見逃した例外などに自分自身を開放していますか?

ドキュメントには次のように記載されています：

Flow インターフェイスのすべての実装は、以下で詳しく説明する 2 つの主要なプロパティに準拠する必要があります。

• コンテキストの保存。
• 例外的な透明性。

しかし、それが私の実装の場合なのか、それとも何か不足しているのかはわかりません。
それとも、もっと良い方法がありますか？

RxJavatoCoroutinesとを使用して現在の実装を置き換えていFlowます。一部のFlow演算子の使用に問題があります。

Flow収集するアイテムを提供する前に、アイテムのリストをフィルタリングしようとしています。( Flow<List<TaskWithCategory>>)

の例を次に示しますRx2。

上記の実装では、既に完了しているTaskWithCategoryによるフィルタリングのリストを提供しています。Task

を使用してこれを達成するにはどうすればよいFlowですか?

私は 1 つの名前をLiveData付け、次に、変更を監視し、それに応じてデータを入力するsortOrderという名前の別の変数を持っています。myDatasortOrder

活動の観察

質問

• Flow/StateFlow出力を変更せずに上記のシナリオを API に置き換えるにはどうすればよいですか?