MCPcopy Create free account
hub / github.com/Rustixir/darkbird / dispatch

Method dispatch

src/darkbird/router.rs:165–173  ·  view source on GitHub ↗
(&mut self, msg: Msg)

Source from the content-addressed store, hash-verified

163
164 #[inline]
165 async fn dispatch(&mut self, msg: Msg) -> Result<(), DestinationDown<Msg>> {
166
167 if self.channels.len() == 0 {
168 return Ok(())
169 }
170
171 self.broadcast(msg).await;
172 Ok(())
173 }
174
175
176 #[inline]

Callers 7

subscribeMethod · 0.80
insertMethod · 0.80
removeMethod · 0.80
handle_recvMethod · 0.80
subscribeMethod · 0.80
insertMethod · 0.80
removeMethod · 0.80

Calls 2

lenMethod · 0.80
broadcastMethod · 0.80

Tested by

no test coverage detected