Skip to content

Commit 728ac1b

Browse files
committed
chore: make message deletion asynchronous for user messages
1 parent efc639e commit 728ac1b

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

packages/stream_chat/lib/src/client/channel.dart

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -3774,18 +3774,18 @@ class ChannelClientState {
37743774
);
37753775
}
37763776

3777-
void _deleteMessagesFromUser({
3777+
Future<void> _deleteMessagesFromUser({
37783778
required String userId,
37793779
bool hardDelete = false,
37803780
DateTime? deletedAt,
3781-
}) {
3781+
}) async {
37823782
// Delete messages from persistence.
37833783
//
37843784
// Note: We perform this operation separately even though [_removeMessages]
37853785
// already handles it as we need to delete all messages from the user, not
37863786
// only the ones present in the current state.
37873787
final persistence = _channel.client.chatPersistenceClient;
3788-
persistence?.deleteMessagesFromUser(
3788+
await persistence?.deleteMessagesFromUser(
37893789
userId: userId,
37903790
cid: _channel.cid,
37913791
hardDelete: hardDelete,
@@ -4140,7 +4140,7 @@ class ChannelClientState {
41404140
// as either soft or hard deleted based on the event data.
41414141
void _listenUserMessagesDeleted() {
41424142
_subscriptions.add(
4143-
_channel.on(EventType.userMessagesDeleted).listen((event) {
4143+
_channel.on(EventType.userMessagesDeleted).listen((event) async {
41444144
final user = event.user;
41454145
if (user == null) return;
41464146

0 commit comments

Comments
 (0)