Fix typos
This commit is contained in:
parent
9189539715
commit
e860333bf3
|
@ -41,7 +41,7 @@ impl<R: Read> fmt::Debug for StreamReader<R> {
|
||||||
|
|
||||||
impl<R: Read> StreamReader<R> {
|
impl<R: Read> StreamReader<R> {
|
||||||
/// Constructs new stream reader for a given input stream `stream`
|
/// Constructs new stream reader for a given input stream `stream`
|
||||||
#[deprecated(since="0.28.0", note="wrap you stream into a buffered reader if necessary and use consensus_encode directly")]
|
#[deprecated(since="0.28.0", note="wrap your stream into a buffered reader if necessary and use consensus_encode directly")]
|
||||||
pub fn new(stream: R, _buffer_size: Option<usize>) -> StreamReader<R> {
|
pub fn new(stream: R, _buffer_size: Option<usize>) -> StreamReader<R> {
|
||||||
StreamReader {
|
StreamReader {
|
||||||
stream: BufReader::new(stream),
|
stream: BufReader::new(stream),
|
||||||
|
@ -49,7 +49,7 @@ impl<R: Read> StreamReader<R> {
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Reads stream and parses next message from its current input
|
/// Reads stream and parses next message from its current input
|
||||||
#[deprecated(since="0.28.0", note="wrap you stream into a buffered reader if necessary and use consensus_encode directly")]
|
#[deprecated(since="0.28.0", note="wrap your stream into a buffered reader if necessary and use consensus_encode directly")]
|
||||||
pub fn read_next<D: Decodable>(&mut self) -> Result<D, encode::Error> {
|
pub fn read_next<D: Decodable>(&mut self) -> Result<D, encode::Error> {
|
||||||
Decodable::consensus_decode(&mut self.stream)
|
Decodable::consensus_decode(&mut self.stream)
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue