Documentation
  • Coverage
  • 0%
    0 out of 9 items documented0 out of 5 items with examples
  • Size
  • Source code size: 7.91 kB This is the summed size of all the files inside the crates.io package for this release.
  • Documentation size: 1.57 MB This is the summed size of all files generated by rustdoc for all configured targets
  • Links
  • martindevans/rust_message_bus
    0 0 0
  • crates.io
  • Dependencies
  • Versions
  • Owners
  • martindevans

This is an implementation of a "message bus" which buffers messages and sends them at the correct timestamp. When a message is sent it is sent with a timestamp, e.g.

bus.sender.send(Message::<valuetype>::new(value, receive_time));

The message will not be received by anything until that time arrives. i.e.

bus.tick(time);

Where time >= receive_time given when sending. When receive_time has arrived the message will be sent to bus.output_receiver