Unnamed repository; edit this file 'description' to name the repository.
correct visibility of transport layer
bit-aloo 3 months ago
parent 154c878 · commit fb67545
-rw-r--r--crates/proc-macro-api/src/transport.rs4
-rw-r--r--crates/proc-macro-api/src/transport/json.rs8
-rw-r--r--crates/proc-macro-api/src/transport/postcard.rs8
3 files changed, 10 insertions, 10 deletions
diff --git a/crates/proc-macro-api/src/transport.rs b/crates/proc-macro-api/src/transport.rs
index e31d6a589d..f383edb0cb 100644
--- a/crates/proc-macro-api/src/transport.rs
+++ b/crates/proc-macro-api/src/transport.rs
@@ -1,3 +1,3 @@
//! Contains construct for transport of messages.
-pub mod json;
-pub mod postcard;
+pub(crate) mod json;
+pub(crate) mod postcard;
diff --git a/crates/proc-macro-api/src/transport/json.rs b/crates/proc-macro-api/src/transport/json.rs
index da79dc5309..f433bb7de0 100644
--- a/crates/proc-macro-api/src/transport/json.rs
+++ b/crates/proc-macro-api/src/transport/json.rs
@@ -3,7 +3,7 @@ use std::io::{self, BufRead, Write};
use serde::{Serialize, de::DeserializeOwned};
-pub fn read<'a, R: BufRead + ?Sized>(
+pub(crate) fn read<'a, R: BufRead + ?Sized>(
inp: &mut R,
buf: &'a mut String,
) -> io::Result<Option<&'a mut String>> {
@@ -28,18 +28,18 @@ pub fn read<'a, R: BufRead + ?Sized>(
}
}
-pub fn write<W: Write + ?Sized>(out: &mut W, buf: &String) -> io::Result<()> {
+pub(crate) fn write<W: Write + ?Sized>(out: &mut W, buf: &String) -> io::Result<()> {
tracing::debug!("> {}", buf);
out.write_all(buf.as_bytes())?;
out.write_all(b"\n")?;
out.flush()
}
-pub fn encode<T: Serialize>(msg: &T) -> io::Result<String> {
+pub(crate) fn encode<T: Serialize>(msg: &T) -> io::Result<String> {
Ok(serde_json::to_string(msg)?)
}
-pub fn decode<T: DeserializeOwned>(buf: &mut str) -> io::Result<T> {
+pub(crate) fn decode<T: DeserializeOwned>(buf: &mut str) -> io::Result<T> {
let mut deserializer = serde_json::Deserializer::from_str(buf);
// Note that some proc-macro generate very deep syntax tree
// We have to disable the current limit of serde here
diff --git a/crates/proc-macro-api/src/transport/postcard.rs b/crates/proc-macro-api/src/transport/postcard.rs
index ddd5f405d5..75aa90e4c4 100644
--- a/crates/proc-macro-api/src/transport/postcard.rs
+++ b/crates/proc-macro-api/src/transport/postcard.rs
@@ -4,7 +4,7 @@ use std::io::{self, BufRead, Write};
use serde::{Serialize, de::DeserializeOwned};
-pub fn read<'a, R: BufRead + ?Sized>(
+pub(crate) fn read<'a, R: BufRead + ?Sized>(
inp: &mut R,
buf: &'a mut Vec<u8>,
) -> io::Result<Option<&'a mut Vec<u8>>> {
@@ -16,15 +16,15 @@ pub fn read<'a, R: BufRead + ?Sized>(
Ok(Some(buf))
}
-pub fn write<W: Write + ?Sized>(out: &mut W, buf: &[u8]) -> io::Result<()> {
+pub(crate) fn write<W: Write + ?Sized>(out: &mut W, buf: &[u8]) -> io::Result<()> {
out.write_all(buf)?;
out.flush()
}
-pub fn encode<T: Serialize>(msg: &T) -> io::Result<Vec<u8>> {
+pub(crate) fn encode<T: Serialize>(msg: &T) -> io::Result<Vec<u8>> {
postcard::to_allocvec_cobs(msg).map_err(|e| io::Error::new(io::ErrorKind::InvalidData, e))
}
-pub fn decode<T: DeserializeOwned>(buf: &mut [u8]) -> io::Result<T> {
+pub(crate) fn decode<T: DeserializeOwned>(buf: &mut [u8]) -> io::Result<T> {
postcard::from_bytes_cobs(buf).map_err(|e| io::Error::new(io::ErrorKind::InvalidData, e))
}