Method register_llm_stream_execution_intercept

crates/python/src/py_plugin.rs:528–560

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

    #[pyo3(signature = (name: "str", priority: "int", callback: "object") -> "None", text_signature = "(name: str, priority: int, callback: object) -> None")]
    fn register_llm_stream_execution_intercept(
        &self,
        name: &str,
        priority: i32,
        callback: Py<PyAny>,
    ) -> PyResult<()> {
        let qualified_name = self.qualify_name(name);
        register_llm_stream_execution_intercept(
            &qualified_name,
            priority,
            wrap_py_llm_stream_exec_intercept_fn(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_llm_stream_execution_intercept(&name_owned)
                    .map(|_| ())
                    .map_err(|e| {
                        PluginError::RegistrationFailed(format!(
                            "llm stream execution intercept deregistration failed: {e}"
                        ))
                    })
            }),
        ));
        Ok(())
    }

    #[pyo3(signature = (
        name: "str",