Reformat code with cargo fmt

src/parser/mod.rs

@@ -203,7 +203,7 @@ impl<B: BufRead + Send + 'static, D: UniprotDatabase> Iterator for ThreadedParse
                             if !self.producer.is_alive() {
                                 self.state = State::Finished
                             }
-                        },
+                        }
                         // queue was disconnected: stop and return an error
                         Err(RecvTimeoutError::Disconnected) => {
                             if self.state != State::Finished {

src/parser/producer.rs

@@ -20,7 +20,6 @@ enum State {
     Finished,
 }
 
-
 #[cfg(feature = "threading")]
 pub struct Producer<B> {
     reader: Option<B>,
@@ -31,12 +30,7 @@ pub struct Producer<B> {
 }
 
 impl<B: BufRead + Send + 'static> Producer<B> {
-
-    pub(super) fn new(
-        reader: B,
-        threads: usize,
-        s_text: Sender<Option<Vec<u8>>>,
-    ) -> Self {
+    pub(super) fn new(reader: B, threads: usize, s_text: Sender<Option<Vec<u8>>>) -> Self {
         Self {
             reader: Some(reader),
             s_text,
@@ -82,15 +76,13 @@ impl<B: BufRead + Send + 'static> Producer<B> {
                             state = State::Finished;
                             // return Some(Err(Error::from(e)));
                         }
-                    }
+                    },
                     State::Reading => {
                         // read until the end of the entry.
                         match reader.read_until(b'>', &mut buffer) {
                             // if a full entry is found, send it
                             Ok(_) if buffer.ends_with(&b"</entry>"[..]) => {
-                                s_text
-                                    .send(Some(buffer.as_slice().to_vec()))
-                                    .ok();
+                                s_text.send(Some(buffer.as_slice().to_vec())).ok();
                                 state = State::Started;
                                 buffer.clear();
                             }
@@ -115,7 +107,7 @@ impl<B: BufRead + Send + 'static> Producer<B> {
                             // otherwise just keep iterating.
                             _ => (),
                         }
-                    }                    
+                    }
                     State::AtEof | State::Finished => break,
                     _ => unimplemented!(),
                 }
@@ -135,4 +127,4 @@ impl<B: BufRead + Send + 'static> Producer<B> {
     pub fn is_alive(&self) -> bool {
         self.alive.load(Ordering::SeqCst)
     }
-}
+}

src/uniparc/mod.rs

@@ -49,7 +49,7 @@ pub fn parse<B: BufRead + Send + 'static>(reader: B) -> Parser<B> {
 ///
 /// println!("{:?}", entry);
 /// ```
-pub fn parse_entry<B: BufRead + Send+ 'static>(reader: B) -> <Parser<B> as Iterator>::Item {
+pub fn parse_entry<B: BufRead + Send + 'static>(reader: B) -> <Parser<B> as Iterator>::Item {
     SequentialParser::parse_entry(reader)
 }
 

src/uniprot/mod.rs

@@ -30,7 +30,7 @@ pub type Parser<B> = super::parser::Parser<B, UniProt>;
 ///
 /// println!("{:#?}", parser.next());
 /// ```
-pub fn parse<B: BufRead + Send+ 'static>(reader: B) -> Parser<B> {
+pub fn parse<B: BufRead + Send + 'static>(reader: B) -> Parser<B> {
     Parser::new(reader)
 }
 
@@ -53,7 +53,7 @@ pub fn parse<B: BufRead + Send+ 'static>(reader: B) -> Parser<B> {
 ///
 /// println!("{:?}", entry);
 /// ```
-pub fn parse_entry<B: BufRead + Send+ 'static>(reader: B) -> <Parser<B> as Iterator>::Item {
+pub fn parse_entry<B: BufRead + Send + 'static>(reader: B) -> <Parser<B> as Iterator>::Item {
     SequentialParser::parse_entry(reader)
 }
 

src/uniref/mod.rs

@@ -48,12 +48,12 @@ pub type Parser<B> = super::parser::Parser<B, UniRef>;
 ///
 /// println!("{:?}", entry);
 /// ```
-pub fn parse<B: BufRead+Send+'static>(reader: B) -> Parser<B> {
+pub fn parse<B: BufRead + Send + 'static>(reader: B) -> Parser<B> {
     Parser::new(reader)
 }
 
 /// Parse a single UniRef entry.
-pub fn parse_entry<B: BufRead+Send+'static>(reader: B) -> <Parser<B> as Iterator>::Item {
+pub fn parse_entry<B: BufRead + Send + 'static>(reader: B) -> <Parser<B> as Iterator>::Item {
     SequentialParser::parse_entry(reader)
 }