Skip to content

Commit fb67545

Browse files
committed
correct visibility of transport layer
1 parent 154c878 commit fb67545

3 files changed

Lines changed: 10 additions & 10 deletions

File tree

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,3 @@
11
//! Contains construct for transport of messages.
2-
pub mod json;
3-
pub mod postcard;
2+
pub(crate) mod json;
3+
pub(crate) mod postcard;

crates/proc-macro-api/src/transport/json.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ use std::io::{self, BufRead, Write};
33

44
use serde::{Serialize, de::DeserializeOwned};
55

6-
pub fn read<'a, R: BufRead + ?Sized>(
6+
pub(crate) fn read<'a, R: BufRead + ?Sized>(
77
inp: &mut R,
88
buf: &'a mut String,
99
) -> io::Result<Option<&'a mut String>> {
@@ -28,18 +28,18 @@ pub fn read<'a, R: BufRead + ?Sized>(
2828
}
2929
}
3030

31-
pub fn write<W: Write + ?Sized>(out: &mut W, buf: &String) -> io::Result<()> {
31+
pub(crate) fn write<W: Write + ?Sized>(out: &mut W, buf: &String) -> io::Result<()> {
3232
tracing::debug!("> {}", buf);
3333
out.write_all(buf.as_bytes())?;
3434
out.write_all(b"\n")?;
3535
out.flush()
3636
}
3737

38-
pub fn encode<T: Serialize>(msg: &T) -> io::Result<String> {
38+
pub(crate) fn encode<T: Serialize>(msg: &T) -> io::Result<String> {
3939
Ok(serde_json::to_string(msg)?)
4040
}
4141

42-
pub fn decode<T: DeserializeOwned>(buf: &mut str) -> io::Result<T> {
42+
pub(crate) fn decode<T: DeserializeOwned>(buf: &mut str) -> io::Result<T> {
4343
let mut deserializer = serde_json::Deserializer::from_str(buf);
4444
// Note that some proc-macro generate very deep syntax tree
4545
// We have to disable the current limit of serde here

crates/proc-macro-api/src/transport/postcard.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ use std::io::{self, BufRead, Write};
44

55
use serde::{Serialize, de::DeserializeOwned};
66

7-
pub fn read<'a, R: BufRead + ?Sized>(
7+
pub(crate) fn read<'a, R: BufRead + ?Sized>(
88
inp: &mut R,
99
buf: &'a mut Vec<u8>,
1010
) -> io::Result<Option<&'a mut Vec<u8>>> {
@@ -16,15 +16,15 @@ pub fn read<'a, R: BufRead + ?Sized>(
1616
Ok(Some(buf))
1717
}
1818

19-
pub fn write<W: Write + ?Sized>(out: &mut W, buf: &[u8]) -> io::Result<()> {
19+
pub(crate) fn write<W: Write + ?Sized>(out: &mut W, buf: &[u8]) -> io::Result<()> {
2020
out.write_all(buf)?;
2121
out.flush()
2222
}
2323

24-
pub fn encode<T: Serialize>(msg: &T) -> io::Result<Vec<u8>> {
24+
pub(crate) fn encode<T: Serialize>(msg: &T) -> io::Result<Vec<u8>> {
2525
postcard::to_allocvec_cobs(msg).map_err(|e| io::Error::new(io::ErrorKind::InvalidData, e))
2626
}
2727

28-
pub fn decode<T: DeserializeOwned>(buf: &mut [u8]) -> io::Result<T> {
28+
pub(crate) fn decode<T: DeserializeOwned>(buf: &mut [u8]) -> io::Result<T> {
2929
postcard::from_bytes_cobs(buf).map_err(|e| io::Error::new(io::ErrorKind::InvalidData, e))
3030
}

0 commit comments

Comments
 (0)