Skip to content
This repository was archived by the owner on Apr 14, 2026. It is now read-only.

Commit 35b2b8b

Browse files
committed
Update mute/unmute EventPool calls
1 parent 1a31ada commit 35b2b8b

1 file changed

Lines changed: 14 additions & 8 deletions

File tree

lib/store/my_user.dart

Lines changed: 14 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -483,8 +483,6 @@ class MyUserRepository implements AbstractMyUserRepository {
483483
Future<void> toggleMute(MuteDuration? mute) async {
484484
Log.debug('toggleMute($mute)', '$runtimeType');
485485

486-
EventPool().add(EventUserUnmuted(myUser.value!.id));
487-
488486
final MuteDuration? muted = myUser.value?.muted;
489487

490488
final Muting? muting = mute == null
@@ -493,12 +491,20 @@ class MyUserRepository implements AbstractMyUserRepository {
493491

494492
myUser.update((u) => u?.muted = muting?.toModel());
495493

496-
try {
497-
await _graphQlProvider.toggleMyUserMute(muting);
498-
} catch (e) {
499-
myUser.update((u) => u?.muted = muted);
500-
rethrow;
494+
handler() async {
495+
Log.debug('toggleMute($mute) handler', '$runtimeType');
496+
try {
497+
await _graphQlProvider.toggleMyUserMute(muting);
498+
} catch (e) {
499+
myUser.update((u) => u?.muted = muted);
500+
rethrow;
501+
}
501502
}
503+
504+
eventPool.add((muting == null)
505+
? EventUserUnmuted(myUser.value!.id).toPoolEntry(handler)
506+
: EventUserMuted(myUser.value!.id, mute ?? MuteDuration.forever())
507+
.toPoolEntry(handler));
502508
}
503509

504510
@override
@@ -683,7 +689,7 @@ class MyUserRepository implements AbstractMyUserRepository {
683689
}
684690
}
685691

686-
if (EventPool().ignore(event)) {
692+
if (eventPool.ignore(event.toPoolEntry())) {
687693
return;
688694
}
689695

0 commit comments

Comments
 (0)