aboutsummaryrefslogtreecommitdiff
path: root/src/serde.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/serde.rs')
-rw-r--r--src/serde.rs47
1 files changed, 4 insertions, 43 deletions
diff --git a/src/serde.rs b/src/serde.rs
index 7ffe8e0..894d59c 100644
--- a/src/serde.rs
+++ b/src/serde.rs
@@ -4,7 +4,7 @@ use core::marker::PhantomData;
use serde::de::{Deserialize, Deserializer, MapAccess, Visitor};
use serde::ser::{Serialize, SerializeMap, Serializer};
-use super::{Entry, Slab};
+use super::{builder::Builder, Slab};
impl<T> Serialize for Slab<T>
where
@@ -39,52 +39,13 @@ where
where
A: MapAccess<'de>,
{
- let mut slab = Slab::with_capacity(map.size_hint().unwrap_or(0));
+ let mut builder = Builder::with_capacity(map.size_hint().unwrap_or(0));
- // same as FromIterator impl
- let mut vacant_list_broken = false;
- let mut first_vacant_index = None;
while let Some((key, value)) = map.next_entry()? {
- if key < slab.entries.len() {
- // iterator is not sorted, might need to recreate vacant list
- if let Entry::Vacant(_) = slab.entries[key] {
- vacant_list_broken = true;
- slab.len += 1;
- }
- // if an element with this key already exists, replace it.
- // This is consistent with HashMap and BtreeMap
- slab.entries[key] = Entry::Occupied(value);
- } else {
- if first_vacant_index.is_none() && slab.entries.len() < key {
- first_vacant_index = Some(slab.entries.len());
- }
- // insert holes as necessary
- while slab.entries.len() < key {
- // add the entry to the start of the vacant list
- let next = slab.next;
- slab.next = slab.entries.len();
- slab.entries.push(Entry::Vacant(next));
- }
- slab.entries.push(Entry::Occupied(value));
- slab.len += 1;
- }
- }
- if slab.len == slab.entries.len() {
- // no vacant entries, so next might not have been updated
- slab.next = slab.entries.len();
- } else if vacant_list_broken {
- slab.recreate_vacant_list();
- } else if let Some(first_vacant_index) = first_vacant_index {
- let next = slab.entries.len();
- match &mut slab.entries[first_vacant_index] {
- Entry::Vacant(n) => *n = next,
- _ => unreachable!(),
- }
- } else {
- unreachable!()
+ builder.pair(key, value)
}
- Ok(slab)
+ Ok(builder.build())
}
}