From 07997e67c900d79dd1e01ed599e2ab2f78a0fdce Mon Sep 17 00:00:00 2001 From: Paul Masurel Date: Sat, 20 Aug 2016 16:38:53 +0900 Subject: [PATCH] Store throws an io::Error --- src/indexer/segment_writer.rs | 3 ++- src/store/writer.rs | 4 +--- 2 files changed, 3 insertions(+), 4 deletions(-) diff --git a/src/indexer/segment_writer.rs b/src/indexer/segment_writer.rs index ce6519393..8b180c62b 100644 --- a/src/indexer/segment_writer.rs +++ b/src/indexer/segment_writer.rs @@ -1,5 +1,6 @@ use Result; use DocId; +use std::io; use schema::Schema; use schema::Document; use schema::Term; @@ -99,7 +100,7 @@ impl SegmentWriter { self.segment_serializer) } - pub fn add_document(&mut self, doc: &Document, schema: &Schema) -> Result<()> { + pub fn add_document(&mut self, doc: &Document, schema: &Schema) -> io::Result<()> { let doc_id = self.max_doc; for (field, field_values) in doc.get_sorted_fields() { // TODO pos collision if the field is redundant diff --git a/src/store/writer.rs b/src/store/writer.rs index 281393c7b..9fbc0faba 100644 --- a/src/store/writer.rs +++ b/src/store/writer.rs @@ -83,9 +83,7 @@ impl StoreWriter { fn write_and_compress_block(&mut self,) -> io::Result<()> { self.intermediary_buffer.clear(); { - let mut encoder = lz4::EncoderBuilder::new() - .build(&mut self.intermediary_buffer) - .unwrap(); + let mut encoder = try!(lz4::EncoderBuilder::new().build(&mut self.intermediary_buffer)); try!(encoder.write_all(&self.current_block)); let (_, encoder_result) = encoder.finish(); try!(encoder_result);