Getting closing errors when using Coroutine Extensions

[har-nick]

Fairly simple repository setup, fetches a table and returns a value as a flow:

@Suppress("UNCHECKED_CAST")
override fun <T : SettingsCollection> getSettingsAsFlow(settingType: KClass<T>): Flow<T?> {
    return transactions.getAllSettings().asFlow().map {
        val settingsTable = it.executeAsOneOrNull()
            when (settingType) {
                InterfaceSettings::class -> settingsTable?.interface_settings
                PlayerSettings::class -> settingsTable?.player_settings
                else -> throw Exception("Attempted access of inaccessible or missing setting.")
            }
    } as Flow<T?>

val interfaceSettings by appComponent.settingsRepo
    .getSettingsAsFlow(InterfaceSettings::class)
    .collectAsStateWithLifecycle(initialValue = null)

However I'm getting a lot of warnings about leaked database connections and failing to close the connection. Are these warnings something I need to worry about? I'd assumed returning a table's contents as a Flow would require the connection to stay open?

A resource failed to call SQLiteConnection.close.

A SQLiteConnection object for database '/data/user/0/com.harnick.soundly/databases/storage.db' was leaked!  Please fix your application to end transactions in progress properly and to close the database when it is no longer needed.

[har-nick]

Seems to be fixed by passing a Dispatcher using flowOn.

val interfaceSettingsFlow = appComponent.settingsRepo
    .getSettingsAsFlow(InterfaceSettings::class)
    .flowOn(Dispatchers.IO)
    .collectAsStateWithLifecycle(initialValue = null)

[ZacSweers]

Why does this fix the leak?