Change ser::{Seq,Map}Visitor to return an optional exact length

This is necessary for formats that serialize the length in the
format stream. Those formats need the exact length, so the
iterator-style size_hint has the wrong semantics.
This commit is contained in:
Erick Tryzelaar
2015-03-12 19:40:46 -07:00
parent 9e454a243a
commit 5dd53e7ea3
4 changed files with 63 additions and 61 deletions
+6 -8
View File
@@ -265,9 +265,8 @@ fn serialize_tuple_struct(
} }
#[inline] #[inline]
fn size_hint(&self) -> (usize, Option<usize>) { fn len(&self) -> Option<usize> {
let size = $len - (self.state as usize); Some($len)
(size, Some(size))
} }
} }
@@ -349,9 +348,8 @@ fn serialize_struct(
} }
#[inline] #[inline]
fn size_hint(&self) -> (usize, Option<usize>) { fn len(&self) -> Option<usize> {
let size = $len - (self.state as usize); Some($len)
(size, Some(size))
} }
} }
@@ -550,8 +548,8 @@ fn serialize_variant(
ast::MethodImplItem( ast::MethodImplItem(
quote_method!(cx, quote_method!(cx,
fn size_hint(&self) -> (usize, Option<usize>) { fn len(&self) -> Option<usize> {
($len - self.state as usize, Some($len - self.state as usize)) Some($len)
} }
) )
), ),
+1 -5
View File
@@ -233,11 +233,7 @@ impl ser::Serializer for Serializer {
fn visit_seq<V>(&mut self, mut visitor: V) -> Result<(), ()> fn visit_seq<V>(&mut self, mut visitor: V) -> Result<(), ()>
where V: ser::SeqVisitor, where V: ser::SeqVisitor,
{ {
let len = match visitor.size_hint() { let len = visitor.len().unwrap_or(0);
(_, Some(len)) => len,
(len, None) => len,
};
let values = Vec::with_capacity(len); let values = Vec::with_capacity(len);
self.state.push(State::Array(values)); self.state.push(State::Array(values));
+26 -18
View File
@@ -163,9 +163,10 @@ pub trait SeqVisitor {
fn visit<S>(&mut self, serializer: &mut S) -> Result<Option<()>, S::Error> fn visit<S>(&mut self, serializer: &mut S) -> Result<Option<()>, S::Error>
where S: Serializer; where S: Serializer;
/// Return the length of the sequence if known.
#[inline] #[inline]
fn size_hint(&self) -> (usize, Option<usize>) { fn len(&self) -> Option<usize> {
(0, None) None
} }
} }
@@ -173,9 +174,10 @@ pub trait MapVisitor {
fn visit<S>(&mut self, serializer: &mut S) -> Result<Option<()>, S::Error> fn visit<S>(&mut self, serializer: &mut S) -> Result<Option<()>, S::Error>
where S: Serializer; where S: Serializer;
/// Return the length of the map if known.
#[inline] #[inline]
fn size_hint(&self) -> (usize, Option<usize>) { fn len(&self) -> Option<usize> {
(0, None) None
} }
} }
@@ -247,6 +249,7 @@ impl<T> Serialize for Option<T> where T: Serialize {
pub struct SeqIteratorVisitor<Iter> { pub struct SeqIteratorVisitor<Iter> {
iter: Iter, iter: Iter,
len: Option<usize>,
first: bool, first: bool,
} }
@@ -254,9 +257,10 @@ impl<T, Iter> SeqIteratorVisitor<Iter>
where Iter: Iterator<Item=T> where Iter: Iterator<Item=T>
{ {
#[inline] #[inline]
pub fn new(iter: Iter) -> SeqIteratorVisitor<Iter> { pub fn new(iter: Iter, len: Option<usize>) -> SeqIteratorVisitor<Iter> {
SeqIteratorVisitor { SeqIteratorVisitor {
iter: iter, iter: iter,
len: len,
first: true, first: true,
} }
} }
@@ -283,8 +287,8 @@ impl<T, Iter> SeqVisitor for SeqIteratorVisitor<Iter>
} }
#[inline] #[inline]
fn size_hint(&self) -> (usize, Option<usize>) { fn len(&self) -> Option<usize> {
self.iter.size_hint() self.len
} }
} }
@@ -297,7 +301,7 @@ impl<'a, T> Serialize for &'a [T]
fn serialize<S>(&self, serializer: &mut S) -> Result<(), S::Error> fn serialize<S>(&self, serializer: &mut S) -> Result<(), S::Error>
where S: Serializer, where S: Serializer,
{ {
serializer.visit_seq(SeqIteratorVisitor::new(self.iter())) serializer.visit_seq(SeqIteratorVisitor::new(self.iter(), Some(self.len())))
} }
} }
@@ -310,12 +314,14 @@ impl<T> Serialize for Vec<T> where T: Serialize {
} }
} }
impl<T> Serialize for BTreeSet<T> where T: Serialize { impl<T> Serialize for BTreeSet<T>
where T: Serialize + Ord,
{
#[inline] #[inline]
fn serialize<S>(&self, serializer: &mut S) -> Result<(), S::Error> fn serialize<S>(&self, serializer: &mut S) -> Result<(), S::Error>
where S: Serializer, where S: Serializer,
{ {
serializer.visit_seq(SeqIteratorVisitor::new(self.iter())) serializer.visit_seq(SeqIteratorVisitor::new(self.iter(), Some(self.len())))
} }
} }
@@ -327,7 +333,7 @@ impl<T, H> Serialize for HashSet<T, H>
fn serialize<S>(&self, serializer: &mut S) -> Result<(), S::Error> fn serialize<S>(&self, serializer: &mut S) -> Result<(), S::Error>
where S: Serializer, where S: Serializer,
{ {
serializer.visit_seq(SeqIteratorVisitor::new(self.iter())) serializer.visit_seq(SeqIteratorVisitor::new(self.iter(), Some(self.len())))
} }
} }
@@ -394,8 +400,8 @@ macro_rules! tuple_impls {
} }
} }
fn size_hint(&self) -> (usize, Option<usize>) { fn len(&self) -> Option<usize> {
($len, Some($len)) Some($len)
} }
} }
@@ -520,6 +526,7 @@ tuple_impls! {
pub struct MapIteratorVisitor<Iter> { pub struct MapIteratorVisitor<Iter> {
iter: Iter, iter: Iter,
len: Option<usize>,
first: bool, first: bool,
} }
@@ -527,9 +534,10 @@ impl<K, V, Iter> MapIteratorVisitor<Iter>
where Iter: Iterator<Item=(K, V)> where Iter: Iterator<Item=(K, V)>
{ {
#[inline] #[inline]
pub fn new(iter: Iter) -> MapIteratorVisitor<Iter> { pub fn new(iter: Iter, len: Option<usize>) -> MapIteratorVisitor<Iter> {
MapIteratorVisitor { MapIteratorVisitor {
iter: iter, iter: iter,
len: len,
first: true, first: true,
} }
} }
@@ -557,8 +565,8 @@ impl<K, V, I> MapVisitor for MapIteratorVisitor<I>
} }
#[inline] #[inline]
fn size_hint(&self) -> (usize, Option<usize>) { fn len(&self) -> Option<usize> {
self.iter.size_hint() self.len
} }
} }
@@ -572,7 +580,7 @@ impl<K, V> Serialize for BTreeMap<K, V>
fn serialize<S>(&self, serializer: &mut S) -> Result<(), S::Error> fn serialize<S>(&self, serializer: &mut S) -> Result<(), S::Error>
where S: Serializer, where S: Serializer,
{ {
serializer.visit_map(MapIteratorVisitor::new(self.iter())) serializer.visit_map(MapIteratorVisitor::new(self.iter(), Some(self.len())))
} }
} }
@@ -585,7 +593,7 @@ impl<K, V, H> Serialize for HashMap<K, V, H>
fn serialize<S>(&self, serializer: &mut S) -> Result<(), S::Error> fn serialize<S>(&self, serializer: &mut S) -> Result<(), S::Error>
where S: Serializer, where S: Serializer,
{ {
serializer.visit_map(MapIteratorVisitor::new(self.iter())) serializer.visit_map(MapIteratorVisitor::new(self.iter(), Some(self.len())))
} }
} }
+30 -30
View File
@@ -33,15 +33,15 @@ pub enum Token<'a> {
NamedUnit(&'a str), NamedUnit(&'a str),
EnumUnit(&'a str, &'a str), EnumUnit(&'a str, &'a str),
SeqStart(usize), SeqStart(Option<usize>),
NamedSeqStart(&'a str, usize), NamedSeqStart(&'a str, Option<usize>),
EnumSeqStart(&'a str, &'a str, usize), EnumSeqStart(&'a str, &'a str, Option<usize>),
SeqSep(bool), SeqSep(bool),
SeqEnd, SeqEnd,
MapStart(usize), MapStart(Option<usize>),
NamedMapStart(&'a str, usize), NamedMapStart(&'a str, Option<usize>),
EnumMapStart(&'a str, &'a str, usize), EnumMapStart(&'a str, &'a str, Option<usize>),
MapSep(bool), MapSep(bool),
MapEnd, MapEnd,
} }
@@ -187,7 +187,7 @@ impl<'a> Serializer for AssertSerializer<'a> {
fn visit_seq<V>(&mut self, visitor: V) -> Result<(), ()> fn visit_seq<V>(&mut self, visitor: V) -> Result<(), ()>
where V: SeqVisitor where V: SeqVisitor
{ {
let (len, _) = visitor.size_hint(); let len = visitor.len();
assert_eq!(self.iter.next(), Some(Token::SeqStart(len))); assert_eq!(self.iter.next(), Some(Token::SeqStart(len)));
@@ -197,7 +197,7 @@ impl<'a> Serializer for AssertSerializer<'a> {
fn visit_named_seq<V>(&mut self, name: &str, visitor: V) -> Result<(), ()> fn visit_named_seq<V>(&mut self, name: &str, visitor: V) -> Result<(), ()>
where V: SeqVisitor where V: SeqVisitor
{ {
let (len, _) = visitor.size_hint(); let len = visitor.len();
assert_eq!(self.iter.next().unwrap(), Token::NamedSeqStart(name, len)); assert_eq!(self.iter.next().unwrap(), Token::NamedSeqStart(name, len));
@@ -210,7 +210,7 @@ impl<'a> Serializer for AssertSerializer<'a> {
visitor: V) -> Result<(), ()> visitor: V) -> Result<(), ()>
where V: SeqVisitor where V: SeqVisitor
{ {
let (len, _) = visitor.size_hint(); let len = visitor.len();
assert_eq!(self.iter.next().unwrap(), Token::EnumSeqStart(name, variant, len)); assert_eq!(self.iter.next().unwrap(), Token::EnumSeqStart(name, variant, len));
@@ -227,7 +227,7 @@ impl<'a> Serializer for AssertSerializer<'a> {
fn visit_map<V>(&mut self, visitor: V) -> Result<(), ()> fn visit_map<V>(&mut self, visitor: V) -> Result<(), ()>
where V: MapVisitor where V: MapVisitor
{ {
let (len, _) = visitor.size_hint(); let len = visitor.len();
assert_eq!(self.iter.next(), Some(Token::MapStart(len))); assert_eq!(self.iter.next(), Some(Token::MapStart(len)));
@@ -237,7 +237,7 @@ impl<'a> Serializer for AssertSerializer<'a> {
fn visit_named_map<V>(&mut self, name: &str, visitor: V) -> Result<(), ()> fn visit_named_map<V>(&mut self, name: &str, visitor: V) -> Result<(), ()>
where V: MapVisitor where V: MapVisitor
{ {
let (len, _) = visitor.size_hint(); let len = visitor.len();
assert_eq!(self.iter.next().unwrap(), Token::NamedMapStart(name, len)); assert_eq!(self.iter.next().unwrap(), Token::NamedMapStart(name, len));
@@ -250,7 +250,7 @@ impl<'a> Serializer for AssertSerializer<'a> {
visitor: V) -> Result<(), ()> visitor: V) -> Result<(), ()>
where V: MapVisitor where V: MapVisitor
{ {
let (len, _) = visitor.size_hint(); let len = visitor.len();
assert_eq!(self.iter.next().unwrap(), Token::EnumMapStart(name, variant, len)); assert_eq!(self.iter.next().unwrap(), Token::EnumMapStart(name, variant, len));
@@ -370,11 +370,11 @@ declare_tests! {
} }
test_slice { test_slice {
&[0][..0] => vec![ &[0][..0] => vec![
Token::SeqStart(0), Token::SeqStart(Some(0)),
Token::SeqEnd, Token::SeqEnd,
], ],
&[1, 2, 3][..] => vec![ &[1, 2, 3][..] => vec![
Token::SeqStart(3), Token::SeqStart(Some(3)),
Token::SeqSep(true), Token::SeqSep(true),
Token::I32(1), Token::I32(1),
@@ -388,23 +388,23 @@ declare_tests! {
} }
test_vec { test_vec {
Vec::<isize>::new() => vec![ Vec::<isize>::new() => vec![
Token::SeqStart(0), Token::SeqStart(Some(0)),
Token::SeqEnd, Token::SeqEnd,
], ],
vec![vec![], vec![1], vec![2, 3]] => vec![ vec![vec![], vec![1], vec![2, 3]] => vec![
Token::SeqStart(3), Token::SeqStart(Some(3)),
Token::SeqSep(true), Token::SeqSep(true),
Token::SeqStart(0), Token::SeqStart(Some(0)),
Token::SeqEnd, Token::SeqEnd,
Token::SeqSep(false), Token::SeqSep(false),
Token::SeqStart(1), Token::SeqStart(Some(1)),
Token::SeqSep(true), Token::SeqSep(true),
Token::I32(1), Token::I32(1),
Token::SeqEnd, Token::SeqEnd,
Token::SeqSep(false), Token::SeqSep(false),
Token::SeqStart(2), Token::SeqStart(Some(2)),
Token::SeqSep(true), Token::SeqSep(true),
Token::I32(2), Token::I32(2),
@@ -416,13 +416,13 @@ declare_tests! {
} }
test_tuple { test_tuple {
(1,) => vec![ (1,) => vec![
Token::SeqStart(1), Token::SeqStart(Some(1)),
Token::SeqSep(true), Token::SeqSep(true),
Token::I32(1), Token::I32(1),
Token::SeqEnd, Token::SeqEnd,
], ],
(1, 2, 3) => vec![ (1, 2, 3) => vec![
Token::SeqStart(3), Token::SeqStart(Some(3)),
Token::SeqSep(true), Token::SeqSep(true),
Token::I32(1), Token::I32(1),
@@ -436,14 +436,14 @@ declare_tests! {
} }
test_btreemap { test_btreemap {
btreemap![1 => 2] => vec![ btreemap![1 => 2] => vec![
Token::MapStart(1), Token::MapStart(Some(1)),
Token::MapSep(true), Token::MapSep(true),
Token::I32(1), Token::I32(1),
Token::I32(2), Token::I32(2),
Token::MapEnd, Token::MapEnd,
], ],
btreemap![1 => 2, 3 => 4] => vec![ btreemap![1 => 2, 3 => 4] => vec![
Token::MapStart(2), Token::MapStart(Some(2)),
Token::MapSep(true), Token::MapSep(true),
Token::I32(1), Token::I32(1),
Token::I32(2), Token::I32(2),
@@ -454,15 +454,15 @@ declare_tests! {
Token::MapEnd, Token::MapEnd,
], ],
btreemap![1 => btreemap![], 2 => btreemap![3 => 4, 5 => 6]] => vec![ btreemap![1 => btreemap![], 2 => btreemap![3 => 4, 5 => 6]] => vec![
Token::MapStart(2), Token::MapStart(Some(2)),
Token::MapSep(true), Token::MapSep(true),
Token::I32(1), Token::I32(1),
Token::MapStart(0), Token::MapStart(Some(0)),
Token::MapEnd, Token::MapEnd,
Token::MapSep(false), Token::MapSep(false),
Token::I32(2), Token::I32(2),
Token::MapStart(2), Token::MapStart(Some(2)),
Token::MapSep(true), Token::MapSep(true),
Token::I32(3), Token::I32(3),
Token::I32(4), Token::I32(4),
@@ -479,7 +479,7 @@ declare_tests! {
} }
test_named_seq { test_named_seq {
NamedSeq(1, 2, 3) => vec![ NamedSeq(1, 2, 3) => vec![
Token::NamedSeqStart("NamedSeq", 3), Token::NamedSeqStart("NamedSeq", Some(3)),
Token::SeqSep(true), Token::SeqSep(true),
Token::I32(1), Token::I32(1),
@@ -493,7 +493,7 @@ declare_tests! {
} }
test_named_map { test_named_map {
NamedMap { a: 1, b: 2, c: 3 } => vec![ NamedMap { a: 1, b: 2, c: 3 } => vec![
Token::NamedMapStart("NamedMap", 3), Token::NamedMapStart("NamedMap", Some(3)),
Token::MapSep(true), Token::MapSep(true),
Token::Str("a"), Token::Str("a"),
Token::I32(1), Token::I32(1),
@@ -511,7 +511,7 @@ declare_tests! {
test_enum { test_enum {
Enum::Unit => vec![Token::EnumUnit("Enum", "Unit")], Enum::Unit => vec![Token::EnumUnit("Enum", "Unit")],
Enum::Seq(1, 2) => vec![ Enum::Seq(1, 2) => vec![
Token::EnumSeqStart("Enum", "Seq", 2), Token::EnumSeqStart("Enum", "Seq", Some(2)),
Token::SeqSep(true), Token::SeqSep(true),
Token::I32(1), Token::I32(1),
@@ -520,7 +520,7 @@ declare_tests! {
Token::SeqEnd, Token::SeqEnd,
], ],
Enum::Map { a: 1, b: 2 } => vec![ Enum::Map { a: 1, b: 2 } => vec![
Token::EnumMapStart("Enum", "Map", 2), Token::EnumMapStart("Enum", "Map", Some(2)),
Token::MapSep(true), Token::MapSep(true),
Token::Str("a"), Token::Str("a"),
Token::I32(1), Token::I32(1),