Register a new subscription.
(&self)
| 90 | |
| 91 | /// Register a new subscription. |
| 92 | pub fn register(&self) -> u64 { |
| 93 | let id = self.next_id.fetch_add(1, Ordering::Relaxed); |
| 94 | self.active.fetch_add(1, Ordering::Relaxed); |
| 95 | debug!(id, "subscription registered"); |
| 96 | id |
| 97 | } |
| 98 | |
| 99 | /// Unregister a subscription (client disconnected). |
| 100 | pub fn unregister(&self, id: u64) { |
no outgoing calls