Merge pull request #6563 from fufesou/fix/is_subed

fix, is_subed()
2023-11-29 23:25:34 +08:00 · 2023-11-29 23:25:34 +08:00 · ead200ea5d
commit ead200ea5d
parent db158e1ffe e146c2606f
1 changed files with 1 additions and 0 deletions
--- a/src/server/service.rs
+++ b/src/server/service.rs
@ -99,6 +99,7 @@ impl<T: Subscriber + From<ConnInner>> Service for ServiceTmpl<T> {

    fn is_subed(&self, id: i32) -> bool {
        self.0.read().unwrap().subscribes.get(&id).is_some()
+            || self.0.read().unwrap().new_subscribes.get(&id).is_some()
    }

    fn on_subscribe(&self, sub: ConnInner) {