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
/Write
for synchronous streamsAsyncRead
/AsyncWrite
fortokio
streamsAsyncRead
/AsyncWrite
forsmol
streams
- Datagrams
- Repliable
- Anonymous
- Primary sessions
tokio
is enabled by default:
yosemite = "0.5.0"
sync
enables synchronous APIs:
yosemite = { version = "0.5.0", default-features = false, features = ["sync"] }
smol
enables asynchronous APIs implemented with smol
:
yosemite = { version = "0.5.0", 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