1 unstable release
0.1.0 | Jul 8, 2024 |
---|
#1224 in Asynchronous
9KB
118 lines
Mias
MiasChannel
is a library for creating channels that can be used to send and receive messages between tasks.
Allowing for easy bi-directional communication between tasks. (Normal channel) And allowing for oneshot responses to be sent back to the sender. (Responder channel)
MiasChannel
at the moment only supports tokio. By wrapping the tokio channels in a more user friendly API for bi-directional communication.
It has a goal of supporting more channels in the future easily by using features to enable different channel implementations.
Responder Channel
The responder channel is a channel that allows for a request to be sent to a receiver and for a response to be sent back to the sender. This is useful for when you want to send a request to a task and get a response back. The responder channel is implemented using a normal channel and oneshot channels.
Is built on top of the normal channel and oneshot channels. In the future i want to replace the oneshot channels with a more efficient implementation.
Responder Channel Example:
use mias_channel::responder_channel;
#[tokio::main]
async fn main() {
let (tx, mut rx) = responder_channel::<i64, f64>(10);
tokio::task::spawn(async move {
while let Some((req, tx)) = rx.recv().await {
tx.send(req as f64).unwrap();
}
});
let res = tx.send(10).await;
}
Dependencies
~2.2–8MB
~63K SLoC