sod-mpsc

sod::Service implementations to interact with std::sync::mpsc queues.

Service Impls

• MpscSender sends to a std::sync::mpsc::channel.
• MpscSyncSender sends to a std::sync::mpsc::sync_channel and blocks if the channel is full.
• MpscSyncTrySender tries to send to a std::sync::mpsc::sync_channel and is able to be retried via sod::RetryService when the channel is full.
• MpscReceiver receives from a std::sync::mpsc::channel or std::sync::mpsc::sync_channel, blocking until an element is received.
• MpscTryReceiver tries to receive from a std::sync::mpsc::channel or std::sync::mpsc::sync_channel, and is able to be retried via sod::Retryable when the channel is empty.

Example

```rust use sod::Service; use sod_mpsc::{MpscSender, MpscReceiver}; use std::sync::mpsc;

let (tx, rx) = mpsc::channel(); let pusher = MpscSender::new(tx); let poller = MpscReceiver::new(rx);

pusher.process(1).unwrap(); pusher.process(2).unwrap();

asserteq!(poller.process(()).unwrap(), 1); asserteq!(poller.process(()).unwrap(), 2); ```