From 9f5dd9dad6b13476bab2c6eb3c6528f8ad49311a Mon Sep 17 00:00:00 2001 From: Till Höppner Date: Thu, 25 Feb 2016 06:48:03 +0100 Subject: Refactor... everything. --- formats/msgpack/src/lib.rs | 62 ++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 62 insertions(+) create mode 100644 formats/msgpack/src/lib.rs (limited to 'formats/msgpack/src') diff --git a/formats/msgpack/src/lib.rs b/formats/msgpack/src/lib.rs new file mode 100644 index 0000000..36af1aa --- /dev/null +++ b/formats/msgpack/src/lib.rs @@ -0,0 +1,62 @@ +// Copyright 2015 Till Höppner +// +// Licensed under the Apache License, Version 2.0 (the "License"); +// you may not use this file except in compliance with the License. +// You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + +use std::io::{BufRead, Write}; +use std::iter::Iterator; + +use event::Event; +use context::Context; +use format::{Decode, Encode}; + +use rustc_serialize::{Decodable, Encodable}; +use msgpack::{Decoder, Encoder}; +use rmp::decode::ReadError; + +pub struct Msgpack; + +pub struct Iter<'a> { + input: &'a mut BufRead, +} + +impl<'a> Iterator for Iter<'a> { + type Item = ::Result>; + fn next(&mut self) -> Option<::Result>> { + use msgpack::decode; + match Event::decode(&mut Decoder::new(&mut self.input)) { + Ok(e) => Some(Ok(e)), + Err(decode::Error::InvalidMarkerRead(ReadError::UnexpectedEOF)) => None, + Err(e) => Some(Err(::IlcError::MsgpackDecode(e))), + } + } +} + +impl Encode for Msgpack { + fn encode<'a>(&'a self, + _context: &'a Context, + output: &'a mut Write, + event: &'a Event) + -> ::Result<()> { + event.encode(&mut Encoder::new(output)) + .map_err(|e| ::IlcError::MsgpackEncode(e)) + } +} + +impl Decode for Msgpack { + fn decode<'a>(&'a mut self, + _context: &'a Context, + input: &'a mut BufRead) + -> Box>> + 'a> { + Box::new(Iter { input: input }) + } +} -- cgit v1.2.3