[reader] fix: synchronization between invokation.

brookst · Jan 3, 2017 · 0d3f905 · 0d3f905
1 parent 4ced871
commit 0d3f905
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/reader.rs b/src/reader.rs
@@ -136,14 +136,14 @@ impl Reader {
                         let query_clone = query.clone();
 
                         // start the new command
-                        thread::spawn(move || {
+                        thread_reader = Some(thread::spawn(move || {
                             let _ = tx_sender_clone.send((Event::EvReaderStarted, Box::new(true)));
                             let _ = tx_sender_clone.send((Event::EvSenderRestart, Box::new(query_clone)));
 
                             reader(&cmd_clone, rx_reader, &tx_sender_clone, option_clone);
 
                             let _ = tx_sender_clone.send((Event::EvReaderStopped, Box::new(true)));
-                        });
+                        }));
                     } else {
                         // tell sender to restart
                         let _ = tx_sender.send((Event::EvSenderRestart, Box::new(query.clone())));