协程

Flow

要将查询作为 Flow 消费，请添加 coroutines extensions 构件作为依赖项，并使用它提供的扩展函数：

Kotlin

dependencies {
  implementation("app.cash.sqldelight:coroutines-extensions:2.1.0")
}

Groovy

dependencies {
  implementation "app.cash.sqldelight:coroutines-extensions:2.1.0"
}

val players: Flow<List<HockeyPlayer>> = 
  playerQueries.selectAll()
    .asFlow()
    .mapToList(Dispatchers.IO)

这个 Flow 会发出查询结果，并且每当数据库针对该查询发生变化时，都会发出新的结果。