Method register_subscriber

crates/python/src/py_plugin.rs:217–238

(&self, name: &str, callback: Py<PyAny>)

        text_signature = "(name: str, callback: object) -> None"
    )]
    fn register_subscriber(&self, name: &str, callback: Py<PyAny>) -> PyResult<()> {
        let qualified_name = self.qualify_name(name);
        register_subscriber(&qualified_name, wrap_py_event_subscriber(callback))
            .map_err(to_py_err)?;

        let name_owned = qualified_name;
        let mut guard = self.registrations.lock().map_err(|e| {
            pyo3::exceptions::PyRuntimeError::new_err(format!("plugin context lock poisoned: {e}"))
        })?;
        guard.push(PluginRegistration::new(
            "plugin",
            name_owned.clone(),
            Box::new(move || {
                deregister_subscriber(&name_owned).map(|_| ()).map_err(|e| {
                    PluginError::RegistrationFailed(format!(
                        "subscriber deregistration failed: {e}"
                    ))
                })
            }),
        ));
        Ok(())
    }

    #[pyo3(signature = (name: "str", priority: "int", callback: "object") -> "None", text_signature = "(name: str, priority: int, callback: object) -> None")]
    fn register_tool_sanitize_request_guardrail(