@@ -55,14 +55,14 @@ impl FileWatcher {
5555 } )
5656 . unwrap ( ) ;
5757
58- let ( mut content_sender , mut content_receiver ) = unbounded :: < Option < String > > ( ) ;
58+ let ( mut _content_sender , mut _content_receiver ) = unbounded :: < Option < String > > ( ) ;
5959 let ( mut _watch_sender, mut _watch_receiver) = unbounded :: < ( ) > ( ) ;
6060 loop {
6161 select ! {
6262 recv( self . receiver) -> msg => {
6363 match msg. unwrap( ) {
6464 FileWatcherMessage :: FilePath ( file_path) => {
65- ( content_sender , content_receiver ) = unbounded( ) ;
65+ ( _content_sender , _content_receiver ) = unbounded( ) ;
6666 ( _watch_sender, _watch_receiver) = unbounded:: <( ) >( ) ;
6767
6868 if let Some ( p) = & self . file_path {
@@ -76,7 +76,7 @@ impl FileWatcher {
7676 Ok ( _) => {
7777 self . file_path = Some ( p) ;
7878 let p = self . file_path. clone( ) ;
79- thread:: spawn( move || FileReader :: new( content_sender , _watch_receiver, p) . run( ) ) ;
79+ thread:: spawn( move || FileReader :: new( _content_sender , _watch_receiver, p) . run( ) ) ;
8080 } ,
8181 Err ( e) => self . app. send( AppMessage :: JobStdout ( Some ( format!( "Failed to watch {:?}: {}" , p, e) ) ) ) . unwrap( )
8282 } ;
@@ -85,7 +85,7 @@ impl FileWatcher {
8585 }
8686 }
8787 recv( watch_receiver) -> _ => { _watch_sender. send( ( ) ) . unwrap( ) ; }
88- recv( content_receiver ) -> msg => {
88+ recv( _content_receiver ) -> msg => {
8989 self . app. send( AppMessage :: JobStdout ( msg. unwrap( ) ) ) . unwrap( ) ;
9090 }
9191 }
0 commit comments