yosemite is a SAMv3 client library for interacting with the I2P network.
It provides synchronous and asynchronous APIs and supports both tokio and smol.
- Streams
- Forwarding
Read/Writefor synchronous streamsAsyncRead/AsyncWritefortokiostreamsAsyncRead/AsyncWriteforsmolstreams
- Datagrams
- Repliable
- Anonymous
- Primary sessions
tokio is enabled by default:
yosemite = "0.6.3"sync enables synchronous APIs:
yosemite = { version = "0.6.3", default-features = false, features = ["sync"] }smol enables asynchronous APIs implemented with smol:
yosemite = { version = "0.6.3", default-features = false, features = ["smol"] }tokio, smol, and sync are all mutually exclusive and only one them can be enabled. The APIs are otherwise the same but tokio and smol require blocking calls to .await.
use tokio::io::AsyncReadExt;
use yosemite::{style::Stream, Session};
#[tokio::main]
async fn main() -> yosemite::Result<()> {
let mut session = Session::<Stream>::new(Default::default()).await?;
while let Ok(mut stream) = session.accept().await {
println!("{} connected", stream.remote_destination());
tokio::spawn(async move {
let mut buffer = vec![0u8; 512];
while let Ok(nread) = stream.read(&mut buffer).await {
println!(
"client sent: {:?}",
std::str::from_utf8(&buffer[..nread])
);
}
});
}
Ok(())
}See examples for instructions on how to use yosemite.
MIT