Benign rust Download

go-netrpc 0.1.0

“Go's net/rpc protocol (gob codec) for async Rust: client and server”

Rust TcpStream::connect callStructured object contains a task sequence field

SHA-2565e1bcc07a8c754696dc4dcf10ce79fb74d177b1bae5de397b2d209b7f00efe42

URLhttps://static.crates.io/crates/go-netrpc/go-netrpc-0.1.0.crate

Evidence

References the Tokio async runtime namespace client.rs · lines 4–10

4:33… onError};
5
6use gobwire::{Decode, Decoder, Encode, Encoder};
7use tokio::io::{AsyncRead, AsyncWrite, AsyncWriteExt, BufReader, ReadHalf, WriteHalf};
8use tokio::sync::oneshot;
9
10use crate::error::Error;

English function-word token "the" client.rs · lines 12–16

12:5… crate::messages::{Request, Response};
13
14/// What the reader task hands a pending call.
15enum Outcome<'a> {
16    /// The reply is buffered in the decod …

Structured object contains a task sequence field client.rs · lines 34–41

34:3…   io: Box<dyn AsyncWrite + Send + Unpin>,
35    enc: Encoder,
36    seq: u64,
37}
38
39struct Shared {
40    /// Held across sequence assignment, encoding and the write, like Go's `reqMutex`: the gob
41    /// stream's type state and the byte order on the  …

English function-word token "with" client.rs · lines 171–173

2…    /// Close the connection. Pending calls fail with [`Error::Shutdown`]; closing twice returns
  /// it too.
  pub async fn close(&self) -> Res …

Rust TcpStream::connect call lib.rs · lines 16–22

16:7…   #[gob(name = "B")]
17//!     b: i64,
18//! }
19//!
20//! let stream = tokio::net::TcpStream::connect("127.0.0.1:1234").await?;
21//! let client = go_netrpc::Client::new(stream);
22//! let product: i64 = client.call("Arith.Multiply",  …

No evidence locations were recorded for this file. Raw result