Crate tachyonix

source ·
Expand description

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§

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

Enums§

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

Functions§

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