17 releases

0.5.1 May 19, 2024
0.5.0 May 19, 2024
0.4.0 Feb 3, 2023
0.3.5 Oct 15, 2022
0.1.0 Apr 23, 2022

#1626 in Network programming

Download history 113/week @ 2024-08-31 101/week @ 2024-09-07 294/week @ 2024-09-14 427/week @ 2024-09-21 343/week @ 2024-09-28 201/week @ 2024-10-05 136/week @ 2024-10-12 62/week @ 2024-10-19 14/week @ 2024-10-26 32/week @ 2024-11-02 23/week @ 2024-11-09 194/week @ 2024-11-16 20/week @ 2024-11-23 14/week @ 2024-11-30 59/week @ 2024-12-07 14/week @ 2024-12-14

280 downloads per month
Used in 2 crates

MIT license

41KB
939 lines

Realm IO

crates.io Released API docs

Realm's high performance IO collections.

Example

use tokio::net::TcpStream;
use realm_io::{bidi_copy, bidi_zero_copy, bidi_copy_buf};
use realm_io::{Pipe, CopyBuffer};

let mut left = TcpStream::connect("abc").await.unwrap();
let mut right = TcpStream::connect("def").await.unwrap();

// direct copy     
bidi_copy(&mut left, &mut right).await;

// zero copy
bidi_zero_copy(&mut left, &mut right).await;

// use custom buffer(vector)
let buf1 = CopyBuffer::new(vec![0; 0x2000]);
let buf2 = CopyBuffer::new(vec![0; 0x2000]);
bidi_copy_buf(&mut left, &mut right, buf1, buf2).await;

// use custom buffer(pipe)
let buf1 = CopyBuffer::new(Pipe::new().unwrap());
let buf2 = CopyBuffer::new(Pipe::new().unwrap());
bidi_copy_buf(&mut left, &mut right, buf1, buf2).await;

About Brutal Shutdown

By default, bidi_copy_buf and other IO functions perform a graceful shutdown.

With the feature brutal-shutdown enabled, these IO functions will decide to perform a brutal shutdown once a FIN packet reaches, which will forcefully close two connections on both sides without waiting for a reply packet.

This is helpful when handling connections from a poorly implemented client or server, which may never shutdown its write side nor close the underlying socket.

Dependencies

~2–10MB
~98K SLoC