Bounded capacity channel.
The channel is a multi-producer, single-consumer (MPSC) bounded queue. It is designed to be used as inbox for actors, following the [actor model].
Simple creation of a channel and sending a message over it.
```rust use std::thread;
use heph_inbox::RecvError;
// Create a new small channel. let (mut sender, mut receiver) = hephinbox::newsmall();
let senderhandle = thread::spawn(move || { if let Err(err) = sender.trysend("Hello world!".to_owned()) { panic!("Failed to send value: {}", err); } });
let receiverhandle = thread::spawn(move || { // NOTE: this is just an example don't actually use a loop like this, it // will waste CPU cycles when the channel is empty! loop { match receiver.tryrecv() { Ok(value) => println!("Got a value: {}", value), Err(RecvError::Empty) => continue, Err(RecvError::Disconnected) => break, } } });
senderhandle.join().unwrap(); receiverhandle.join().unwrap(); ```
Licensed under the MIT license (LICENSE or https://opensource.org/licenses/MIT).
Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in the work by you shall be licensed as above, without any additional terms or conditions.