Goal: Add extensions for Kotlin Flow.

Purpose:

• Provide first-class support for consumers using Kotlin Flow.
• Provide API(s) to listen for changes in the database.