#transport-layer #fibers #udp #abstraction #peer #built #top

fibers_transport

Transport layer abstraction built on top of [fibers] crate

4 releases

0.1.3 Sep 11, 2020
0.1.2 Sep 17, 2018
0.1.1 Sep 17, 2018
0.1.0 Sep 16, 2018

#1799 in Asynchronous

Download history 49/week @ 2024-03-11 51/week @ 2024-03-18 38/week @ 2024-03-25 47/week @ 2024-04-01 23/week @ 2024-04-08 16/week @ 2024-04-15 30/week @ 2024-04-22 32/week @ 2024-04-29 5/week @ 2024-05-06 20/week @ 2024-05-13 7/week @ 2024-05-20 7/week @ 2024-05-27 8/week @ 2024-06-03 13/week @ 2024-06-10 23/week @ 2024-06-17 9/week @ 2024-06-24

54 downloads per month
Used in 2 crates

MIT license

39KB
772 lines

fibers_transport

Crates.io: fibers_transport Documentation Actions Status Coverage Status License: MIT

Transport layer abstraction built on top of fibers crate.

Documentation

Examples

UDP peers.

use bytecodec::bytes::{Utf8Decoder, Utf8Encoder};
use fibers_transport::{Transport, UdpTransport, UdpTransporter, wait_send, wait_recv};

type UdpPeer = UdpTransporter<Utf8Encoder, Utf8Decoder>;

// Binds peers.
let mut peer0 = fibers_global::execute(UdpPeer::bind("127.0.0.1:0".parse().unwrap()))?;
let peer1 = fibers_global::execute(UdpPeer::bind("127.0.0.1:0".parse().unwrap()))?;

// `peer0` sends a message to `peer1`.
peer0.start_send(peer1.local_addr(), "foo".to_owned())?;
let peer0 = fibers_global::execute(wait_send(peer0))?;

// `peer1` receives a message from `peer0`.
let (_, addr, item) = fibers_global::execute(wait_recv(peer1))?;
assert_eq!(addr, peer0.local_addr());
assert_eq!(item, "foo");

TCP server and client.

use bytecodec::fixnum::{U8Decoder, U8Encoder};
use factory::DefaultFactory;
use fibers_transport::{Transport, TcpListener, TcpTransport, TcpTransporter, wait_send, wait_recv};
use futures::Stream;

type TcpServer = TcpListener<DefaultFactory<U8Encoder>, DefaultFactory<U8Decoder>>;
type TcpClient = TcpTransporter<U8Encoder, U8Decoder>;

let server = fibers_global::execute(TcpServer::listen("127.0.0.1:0".parse().unwrap()))?;
let mut client = fibers_global::execute(TcpClient::connect(server.local_addr()))?;

// Sends a message to the server.
client.start_send((), 123)?;
let client = fibers_global::execute(wait_send(client))?;

// Receives the message from the client.
let (server, _) = fibers_global::execute(server.into_future()).map_err(|(e, _)| e)?;
let server = server.unwrap();
assert_eq!(server.peer_addr(), client.local_addr());

let (mut server, _, item) = fibers_global::execute(wait_recv(server))?;
assert_eq!(item, 123);

// Replies to the client.
server.start_send((), 9)?;
let _ = fibers_global::execute(wait_send(server))?;

// Receives the reply from the server.
let (_, _, item) = fibers_global::execute(wait_recv(client))?;
assert_eq!(item, 9);

Dependencies

~3MB
~62K SLoC