微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

SqlDelight,MySql和Flow:数据库更改时未调用Flow的collection lambda

如何解决SqlDelight,MySql和Flow:数据库更改时未调用Flow的collection lambda

我在使用Kotlin和Flow消耗查询结果的普通JVM项目中使用MysqL与Hikary数据源一起使用sqlDelight。 查询的第一次执行将按预期返回数据,但是,当数据库上的数据发生更改时,不会触发Flow#emit()。

这是我正在调用的存储库功能

fun getAllUser(): Flow<List<User>> = database.userQueries.getAll()
      .asFlow()
      .mapToList()

这是调用存储库功能的主要功能

    fun main() = runBlocking<Unit> {   repository.getAllUser().collect {
      println("Collecting users: $it")
   }
}

我已经尝试调试基础代码,并且Query对象上的侦听器已注册,并且在执行存储库功能时正确阻止了main。 其他人也经历过类似的事情吗?

解决方法

太蠢了,我的坏蛋!我正在手动更新数据库,并期望看到Flow神奇地更新。无论如何,通过SqlDelight函数更新数据库会使Flow像预期的那样发出更新的记录集。

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。