aboutsummaryrefslogtreecommitdiff
path: root/src/format
diff options
context:
space:
mode:
authorTill Hoeppner2015-07-23 22:57:43 +0200
committerTill Hoeppner2015-07-23 22:57:43 +0200
commit96013802eb8cb8da86b5f6398e88375203cd5e28 (patch)
treec6e7b69a84e52a59bfec2a14d49058dc185964ae /src/format
parenta4ed13e46fcef39d53126b3dc11d4f3705237b60 (diff)
downloadilc-96013802eb8cb8da86b5f6398e88375203cd5e28.tar.gz
ilc-96013802eb8cb8da86b5f6398e88375203cd5e28.tar.xz
ilc-96013802eb8cb8da86b5f6398e88375203cd5e28.zip
Support dynamic selection of decoders/encoders
Diffstat (limited to 'src/format')
-rw-r--r--src/format/binary.rs3
-rw-r--r--src/format/energymech.rs3
-rw-r--r--src/format/mod.rs18
-rw-r--r--src/format/weechat3.rs5
4 files changed, 23 insertions, 6 deletions
diff --git a/src/format/binary.rs b/src/format/binary.rs
index 4c2e151..a1ca12d 100644
--- a/src/format/binary.rs
+++ b/src/format/binary.rs
@@ -44,7 +44,8 @@ impl<'a, W> Encode<'a, W> for Binary where W: Write {
}
}
-impl<'a, R: 'a> Decode<'a, R, Iter<'a, R>> for Binary where R: BufRead {
+impl<'a, R: 'a> Decode<'a, R> for Binary where R: BufRead {
+ type Output = Iter<'a, R>;
fn decode(&'a mut self, _context: &'a Context, input: R) -> Iter<R> {
Iter { _phantom: PhantomData, input: input }
}
diff --git a/src/format/energymech.rs b/src/format/energymech.rs
index 1fdc537..0e46dce 100644
--- a/src/format/energymech.rs
+++ b/src/format/energymech.rs
@@ -151,7 +151,8 @@ impl<'a, R: 'a> Iterator for Iter<'a, R> where R: BufRead {
}
}
-impl<'a, R: 'a> Decode<'a, R, Iter<'a, R>> for Energymech where R: BufRead {
+impl<'a, R: 'a> Decode<'a, R> for Energymech where R: BufRead {
+ type Output = Iter<'a, R>;
fn decode(&'a mut self, context: &'a Context, input: R) -> Iter<R> {
Iter {
context: context,
diff --git a/src/format/mod.rs b/src/format/mod.rs
index db86a1d..2a36b34 100644
--- a/src/format/mod.rs
+++ b/src/format/mod.rs
@@ -30,8 +30,22 @@ pub trait Encode<'a, W> where W: Write {
fn encode(&'a self, context: &'a Context, output: W, event: &'a Event) -> ::Result<()>;
}
-pub trait Decode<'a, R, O> where R: BufRead, O: Iterator<Item = ::Result<Event<'a>>> {
- fn decode(&'a mut self, context: &'a Context, input: R) -> O;
+pub trait Decode<'a, Input> where Input: BufRead,
+ Self::Output: Iterator<Item = ::Result<Event<'a>>> + 'a {
+ type Output;
+ fn decode(&'a mut self, context: &'a Context, input: Input) -> Self::Output;
+}
+
+pub trait DecodeBox<'a, I> {
+ fn decode_box(&'a mut self, context: &'a Context, input: I)
+ -> Box<Iterator<Item = ::Result<Event>> + 'a>;
+}
+
+impl<'a, T, I: BufRead> DecodeBox<'a, I> for T where T: Decode<'a, I> {
+ fn decode_box(&'a mut self, context: &'a Context, input: I)
+ -> Box<Iterator<Item = ::Result<Event>> + 'a> {
+ Box::new(self.decode(context, input))
+ }
}
fn rejoin(s: &[&str], splits: &[char]) -> Cow<'static, str> {
diff --git a/src/format/weechat3.rs b/src/format/weechat3.rs
index 9e07e92..3ff781c 100644
--- a/src/format/weechat3.rs
+++ b/src/format/weechat3.rs
@@ -137,8 +137,9 @@ impl<'a, R: 'a> Iterator for Iter<'a, R> where R: BufRead {
}
}
-impl<'a, R: 'a> Decode<'a, R, Iter<'a, R>> for Weechat3 where R: BufRead {
- fn decode(&'a mut self, context: &'a Context, input: R) -> Iter<R> {
+impl<'a, I: 'a> Decode<'a, I> for Weechat3 where I: BufRead {
+ type Output = Iter<'a, I>;
+ fn decode(&'a mut self, context: &'a Context, input: I) -> Iter<'a, I> {
Iter {
context: context,
input: input,