rust/tantivy
1
0
Fork 0
mirror of https://github.com/quickwit-oss/tantivy.git synced 2026-01-09 02:22:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

Test on UTF-8

Browse Source
This commit is contained in:
Paul Masurel
2017-04-15 09:43:12 +09:00
parent 7eec9f038d
commit c8d06d63b9
3 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/common/counting_writer.rs
View File

@@ -47,8 +47,8 @@ mod test {
#[test]
fn test_counting_writer() {
let mut w: Vec<u8> = vec!();
let mut counting_writer = CountingWriter::wrap(w);
let buffer: Vec<u8> = vec!();
let mut counting_writer = CountingWriter::wrap(buffer);
let bytes = (0u8..10u8).collect::<Vec<u8>>();
counting_writer.write_all(&bytes).unwrap();
let (w, len): (Vec<u8>, usize) = counting_writer.finish().unwrap();

2
src/core/term_iterator.rs
View File

@@ -99,7 +99,7 @@ impl<'a> TermIterator<'a> {
fn advance_segments(&mut self) {
for segment_ord in self.current_segment_ords.drain(..) {
if let Some((term, val)) = self.key_streams[segment_ord].next() {
if let Some((term, _val)) = self.key_streams[segment_ord].next() {
self.heap.push(HeapItem {
term: Term::from_bytes(term),
segment_ord: segment_ord,

10
src/datastruct/stream_dictionary.rs
View File

@@ -266,7 +266,7 @@ fn get_offset<'a, V, P: Fn(&[u8])->bool>(predicate: P, mut streamer: StreamDicti
impl<'a, V: 'a + BinarySerializable + Clone + Default> StreamDictionaryStreamerBuilder<'a, V> {
pub fn ge(mut self, target_key: &[u8]) -> StreamDictionaryStreamerBuilder<'a, V> {
let mut streamer = stream_before(&self.stream_dictionary, target_key.as_ref());
let streamer = stream_before(&self.stream_dictionary, target_key.as_ref());
let smaller_than = |k: &[u8]| { k.lt(target_key) };
let (offset_before, current_key, _) = get_offset(smaller_than, streamer);
self.current_key = current_key;
@@ -275,7 +275,7 @@ impl<'a, V: 'a + BinarySerializable + Clone + Default> StreamDictionaryStreamerB
}
pub fn gt(mut self, target_key: &[u8]) -> StreamDictionaryStreamerBuilder<'a, V> {
let mut streamer = stream_before(self.stream_dictionary, target_key.as_ref());
let streamer = stream_before(self.stream_dictionary, target_key.as_ref());
let smaller_than = |k: &[u8]| { k.le(target_key) };
let (offset_before, current_key, _) = get_offset(smaller_than, streamer);
self.current_key = current_key;
@@ -284,7 +284,7 @@ impl<'a, V: 'a + BinarySerializable + Clone + Default> StreamDictionaryStreamerB
}
pub fn lt(mut self, target_key: &[u8]) -> StreamDictionaryStreamerBuilder<'a, V> {
let mut streamer = stream_before(self.stream_dictionary, target_key.as_ref());
let streamer = stream_before(self.stream_dictionary, target_key.as_ref());
let smaller_than = |k: &[u8]| { k.le(target_key) };
let (_, _, offset_after) = get_offset(smaller_than, streamer);
self.offset_to = offset_after;
@@ -292,7 +292,7 @@ impl<'a, V: 'a + BinarySerializable + Clone + Default> StreamDictionaryStreamerB
}
pub fn le(mut self, target_key: &[u8]) -> StreamDictionaryStreamerBuilder<'a, V> {
let mut streamer = stream_before(self.stream_dictionary, target_key.as_ref());
let streamer = stream_before(self.stream_dictionary, target_key.as_ref());
let smaller_than = |k: &[u8]| { k.lt(target_key) };
let (_, _, offset_after) = get_offset(smaller_than, streamer);
self.offset_to = offset_after;
@@ -408,7 +408,7 @@ mod test {
for j in 0..3 {
let (streamer_k, streamer_v) = streamer.next().unwrap();
let &(ref key, ref v) = &ids[i + j];
assert_eq!(streamer_k, key.as_bytes());
assert_eq!(str::from_utf8(streamer_k).unwrap(), key);
assert_eq!(streamer_v, v);
}
}