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

#677 in Network programming

Download history 32/week @ 2024-06-24 368/week @ 2024-07-01 36/week @ 2024-07-08 131/week @ 2024-07-15 49/week @ 2024-07-22 15/week @ 2024-07-29 2/week @ 2024-08-05 8/week @ 2024-08-19 117/week @ 2024-08-26 166/week @ 2024-09-02 2/week @ 2024-09-09 448/week @ 2024-09-16 350/week @ 2024-09-23 313/week @ 2024-09-30 160/week @ 2024-10-07

1,271 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
~95K SLoC