stynx_code_engine/application/
sub_agent_sink.rs1use stynx_code_types::EngineEvent;
2use tokio::sync::mpsc;
3
4tokio::task_local! {
5 pub static SUB_AGENT_SINK: mpsc::UnboundedSender<EngineEvent>;
6}
7
8pub fn send(event: EngineEvent) {
9 let _ = SUB_AGENT_SINK.try_with(|tx| tx.send(event));
10}