Crate tachyonix

A very fast asynchronous, multi-producer, single-consumer (MPSC) bounded channel.

This is a no-frills async bounded MPSC channel which only claim to fame is to be extremely fast, without taking any shortcuts on correctness and implementation quality.

Disconnection

The channel is disconnected automatically once all Senders are dropped or once the Receiver is dropped. It can also be disconnected manually by any Sender or Receiver handle.

Disconnection is signaled by the Result of the sending or receiving operations. Once a channel is disconnected, all attempts to send a message will return an error. However, the receiver will still be able to receive messages already in the channel and will only get a disconnection error once all messages have been received.

Example

use tachyonix;
use futures_executor::{block_on, ThreadPool};

let pool = ThreadPool::new().unwrap();

let (s, mut r) = tachyonix::channel(3);

block_on( async move {
    pool.spawn_ok( async move {
        assert_eq!(s.send("Hello").await, Ok(()));
    });
     
    assert_eq!(r.recv().await, Ok("Hello"));
});

Structs

• Receiver
  The receiving side of a channel.
• RecvError
  An error returned when an attempt to receive a message asynchronously is unsuccessful.
• SendError
  An error returned when an attempt to send a message asynchronously is unsuccessful.
• Sender
  The sending side of a channel.

Enums

• RecvTimeoutError
  An error returned when an attempt to receive a message asynchronously with a deadline is unsuccessful.
• SendTimeoutError
  An error returned when an attempt to send a message asynchronously with a deadline is unsuccessful.
• TryRecvError
  An error returned when an attempt to receive a message synchronously is unsuccessful.
• TrySendError
  An error returned when an attempt to send a message synchronously is unsuccessful.

Functions

• channel
  Creates a new channel, returning the sending and receiving sides.