mezzenger-tcp

为 mezzenger 提供的 TCP 传输。

https://crates.io/crates/mezzenger-tcp

注意

尽管名称中包含 TCP，但此 crate 支持其他传输方式，只要它们实现了 AsyncRead 和 AsyncWrite 特性。

用法

将依赖项添加到 Cargo.toml

[dependencies]
# ...
serde = { version = "1", features = ["derive"] }
kodec = { version = "0.1.0", features = ["binary"] } # or json or different one from another crate...
mezzenger = "0.1.3"
mezzenger-tcp = "0.1.1"

请参阅此处示例代码 here.

另请参阅

mezzenger

lib.rs:

通过 tokio TCP 实现进行通信的传输。

有关更多信息，请参阅 repository.

示例

let tcp_stream = TcpStream::connect("127.0.0.1:8080").await?;

use kodec::binary::Codec;
let mut transport: Transport<_, Codec, i32, String> =
    Transport::new(tcp_stream, Codec::default());

use mezzenger::Receive;
let integer = transport.receive().await?;

transport.send("Hello World!".to_string()).await?;