message_bus
| Crates.io | message_bus |
| lib.rs | message_bus |
| version | 0.1.0 |
| source | src |
| created_at | 2015-04-27 01:27:01.349575 |
| updated_at | 2015-12-11 23:54:10.497015 |
| description | A message bus which delays messages until a specified timestamp in the future |
| homepage | |
| repository | https://github.com/martindevans/rust_message_bus |
| max_upload_size | |
| id | 1969 |
| size | 7,755 |
publish (github:pistondevelopers:publish)
documentation
README
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