From cd182daf35eae3739511f3751843ad01f0d489b3 Mon Sep 17 00:00:00 2001
From: Till Hoeppner
Date: Thu, 16 Apr 2015 23:32:00 +0200
Subject: Add untested support for binary serialization with rustc_serialize
 and bincode

---
 src/format/binary.rs | 33 +++++++++++++++++++++++++++++++++
 1 file changed, 33 insertions(+)
 create mode 100644 src/format/binary.rs

(limited to 'src/format/binary.rs')

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 }
+    }
+}
-- 
cgit v1.2.3