Handle a ShapeUnsubscribe message.
(session_id: &str, msg: &ShapeUnsubscribeMsg, registry: &ShapeRegistry)
| 133 | |
| 134 | /// Handle a ShapeUnsubscribe message. |
| 135 | pub fn handle_unsubscribe(session_id: &str, msg: &ShapeUnsubscribeMsg, registry: &ShapeRegistry) { |
| 136 | registry.unsubscribe(session_id, &msg.shape_id); |
| 137 | debug!(session = session_id, shape_id = %msg.shape_id, "shape unsubscribed"); |
| 138 | } |
| 139 | |
| 140 | /// Evaluate a mutation against all shapes and generate ShapeDelta frames. |
| 141 | /// |