diff options
author | Till Hoeppner | 2015-04-16 23:32:00 +0200 |
---|---|---|
committer | Till Hoeppner | 2015-04-16 23:32:00 +0200 |
commit | cd182daf35eae3739511f3751843ad01f0d489b3 (patch) | |
tree | 1ce4274d6107b2fe5c87f71437fd9aa988cf090b /src/format/binary.rs | |
parent | 8bf21091210af570a74a29eb731a867c0788ebdb (diff) | |
download | ilc-cd182daf35eae3739511f3751843ad01f0d489b3.tar.gz ilc-cd182daf35eae3739511f3751843ad01f0d489b3.tar.xz ilc-cd182daf35eae3739511f3751843ad01f0d489b3.zip |
Add untested support for binary serialization with rustc_serialize and bincode
Diffstat (limited to 'src/format/binary.rs')
-rw-r--r-- | src/format/binary.rs | 33 |
1 files changed, 33 insertions, 0 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 } + } +} |