Unnamed repository; edit this file 'description' to name the repository.
correct visibility of transport layer
| -rw-r--r-- | crates/proc-macro-api/src/transport.rs | 4 | ||||
| -rw-r--r-- | crates/proc-macro-api/src/transport/json.rs | 8 | ||||
| -rw-r--r-- | crates/proc-macro-api/src/transport/postcard.rs | 8 |
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)) } |