#io #reconnect #retry #stubborn #stubborn-tcp-stream

stubborn-io

io traits/structs that automatically recover from potential disconnections/interruptions

19 releases

0.3.5 May 8, 2024
0.3.4 Jan 25, 2024
0.3.3 Dec 13, 2023
0.3.2 Sep 30, 2022
0.1.0 Jul 31, 2019

#211 in Network programming

Download history 4144/week @ 2024-08-03 3470/week @ 2024-08-10 4194/week @ 2024-08-17 3687/week @ 2024-08-24 3505/week @ 2024-08-31 3174/week @ 2024-09-07 3069/week @ 2024-09-14 3100/week @ 2024-09-21 3634/week @ 2024-09-28 3371/week @ 2024-10-05 3084/week @ 2024-10-12 3397/week @ 2024-10-19 3969/week @ 2024-10-26 3589/week @ 2024-11-02 3184/week @ 2024-11-09 2874/week @ 2024-11-16

14,188 downloads per month
Used in 3 crates

MIT license

32KB
615 lines

stubborn-io

This crate provides io traits/structs that automatically recover from potential disconnections/interruptions.

To use with your project, add the following to your Cargo.toml:

stubborn-io = "0.3"

API Documentation, examples and motivations can be found here - https://docs.rs/stubborn-io .

Usage Example

In this example, we will see a drop in replacement for tokio's TcpStream, with the distinction that it will automatically attempt to reconnect in the face of connectivity failures.

use stubborn_io::StubbornTcpStream;
use tokio::io::AsyncWriteExt;

let addr = "localhost:8080";

// we are connecting to the TcpStream using the default built in options.
// these can also be customized (for example, the amount of reconnect attempts,
// wait duration, etc) using the connect_with_options method.
let mut tcp_stream = StubbornTcpStream::connect(addr).await?;
// once we acquire the wrapped IO, in this case, a TcpStream, we can
// call all of the regular methods on it, as seen below
tcp_stream.write_all(b"hello world!").await?;

Dependencies

~3–11MB
~98K SLoC