nndeploy.server.task_bus

Functions

clear_emitter()
emit_llm_delta(delta_text)
install_emitter(pid, emit)

nndeploy.server.task_bus.install_emitter(pid: int, emit: Callable[[Dict[str, Any]], None]) → None

nndeploy.server.task_bus.clear_emitter() → None

nndeploy.server.task_bus.emit_llm_delta(delta_text: str) → None