fun ContentResolver.observeQuery(
uri: Uri,
projection: Array<String>? = null,
selection: String? = null,
selectionArgs: Array<String>? = null,
sortOrder: String? = null,
notifyForDescendants: Boolean = false
): Flow<Query> {
val query = ContentResolverQuery(this, uri, projection, selection, selectionArgs, sortOrder)
return flow {
emit(query)
val channel = Channel<Unit>(CONFLATED)
val observer = object : ContentObserver(mainThread) {
override fun onChange(selfChange: Boolean) {
channel.offer(Unit)
}
}
registerContentObserver(uri, notifyForDescendants, observer)
try {
for (item in channel) {
emit(query)
}
} finally {
unregisterContentObserver(observer)
}
}
}
👉 FlowContentResolver.kt#L43-L90
👉 copper/FlowContentResolver.kt at trunk · cashapp/copper
Kotlin coroutines Flow や RxJava Observable を使ったリアクティブクエリ用の ContentProvider のラッパーです。
使用方法
implementation 'app.cash.copper:copper-flow:1.0.0'
ContentResolver で query() を observeQuery() に変更することで、リアクティブ版を実現します。
contentResolver.observeQuery(uri).collect { query ->
query.run()?.use { cursor ->
// ...
}
}
query() とは異なり、observeQuery() は Query オブジェクトを返します。このオブジェクトは、カーソルの基礎となるクエリを実行するために run() を呼び出す必要があります。これにより、値をキャッシュする中間オペレータがリソースをリークすることなく、コンシューマーがカーソルのライフタイム全体にアクセスできるようになります。
cursor を直接処理する代わりに、含まれる値をセマンティックタイプに変換するためのオペレータを提供しています。
contentResolver.observeQuery(uri)
.mapToOne { cursor ->
Employee(cursor.getString(0), cursor.getString(1))
}
.collect {
println(it)
}
Employee(id=bob, name=Bob Bobberson)
mapToOne オペレータは、1 つの行を返すクエリを受け取り、ラムダを起動してカーソルを希望の型にマッピングします。クエリがゼロまたは1行を返す場合は、コルーチン成果物には mapToOneOrNull オペレータがあり、RxJava成果物には mapToOptional 演算子があります。
クエリがリストを返す場合は、同じラムダでmapToListを呼び出します。
contentResolver.observeQuery(uri)
.mapToList { cursor ->
Employee(cursor.getString(0), cursor.getString(1))
}
.collect {
println(it)
}
[Employee(id=alice, name=Alice Alison), Employee(id=bob, name=Bob Bobberson)]
安定の神Jake産です。
