diff --git a/lib/src/database/daos/contacts_dao.dart b/lib/src/database/daos/contacts_dao.dart index 6a703e1..f43eba5 100644 --- a/lib/src/database/daos/contacts_dao.dart +++ b/lib/src/database/daos/contacts_dao.dart @@ -131,7 +131,7 @@ class ContactsDao extends DatabaseAccessor } Stream watchContactsBlocked() { - final count = contacts.blocked.count(distinct: true); + final count = contacts.userId.count(); final query = selectOnly(contacts)..where(contacts.blocked.equals(true)); query.addColumns([count]); return query.map((row) => row.read(count)).watchSingle();