diff options
Diffstat (limited to 'src/format')
-rw-r--r-- | src/format/binary.rs | 33 | ||||
-rw-r--r-- | src/format/mod.rs | 3 | ||||
-rw-r--r-- | src/format/weechat3.rs | 2 |
3 files changed, 36 insertions, 2 deletions
diff --git a/src/format/binary.rs b/src/format/binary.rs new file mode 100644 index 0000000..aae760c --- /dev/null +++ b/src/format/binary.rs @@ -0,0 +1,33 @@ +use std::io::{ self, BufRead, Write }; +use std::borrow::ToOwned; +use std::iter::{ Iterator }; + +use log::Event; +use format::{ Encode, Decode }; + +use bincode::{ self, SizeLimit }; + +pub struct Binary; + +pub struct Iter<R> where R: BufRead { + input: R, +} + +impl<R> Iterator for Iter<R> where R: BufRead { + type Item = ::Result<Event>; + fn next(&mut self) -> Option<::Result<Event>> { + Some(bincode::decode_from(&mut self.input, SizeLimit::Infinite).map_err(|_| ::IlcError::BincodeDecode)) + } +} + +impl<W> Encode<W> for Binary where W: Write { + fn encode(&self, mut output: W, event: &Event) -> ::Result<()> { + bincode::encode_into(event, &mut output, SizeLimit::Infinite).map_err(|_| ::IlcError::BincodeEncode) + } +} + +impl<R> Decode<R, Iter<R>> for Binary where R: BufRead { + fn decode(&mut self, input: R) -> Iter<R> { + Iter { input: input } + } +} diff --git a/src/format/mod.rs b/src/format/mod.rs index 9f6d30d..2c271bd 100644 --- a/src/format/mod.rs +++ b/src/format/mod.rs @@ -7,9 +7,10 @@ use std::io::{ self, BufRead, Write }; use log::Event; pub mod weechat3; +pub mod binary; pub trait Encode<W> where W: Write { - fn encode(&self, output: W, event: &Event) -> io::Result<()>; + fn encode(&self, output: W, event: &Event) -> ::Result<()>; } pub trait Decode<R, O> where R: BufRead, O: Iterator<Item = ::Result<Event>> { diff --git a/src/format/weechat3.rs b/src/format/weechat3.rs index 0904ced..59bb072 100644 --- a/src/format/weechat3.rs +++ b/src/format/weechat3.rs @@ -95,7 +95,7 @@ impl<R> Decode<R, Iter<R>> for Weechat3 where R: BufRead { } impl<W> Encode<W> for Weechat3 where W: Write { - fn encode(&self, mut output: W, event: &Event) -> io::Result<()> { + fn encode(&self, mut output: W, event: &Event) -> ::Result<()> { fn date(t: i64) -> String { format!("{}", UTC.timestamp(t, 0).format(TIME_DATE_FORMAT)) } |