Register a new change stream.
(&self, def: ChangeStreamDef)
| 96 | |
| 97 | /// Register a new change stream. |
| 98 | pub fn register(&self, def: ChangeStreamDef) { |
| 99 | self.write().insert(def); |
| 100 | } |
| 101 | |
| 102 | /// Unregister a change stream by name. Returns true if it existed. |
| 103 | pub fn unregister(&self, tenant_id: u64, name: &str) -> bool { |