@@ -81,7 +81,7 @@ struct RtContext {
8181
8282/// Create the server runtime from the provided read and write channels.
8383/// This lives for the lifespan of the process.
84- pub async fn spawn ( read : impl Read , write : impl Write , project_dir : & Path ) -> Result < ( ) , Error > {
84+ pub async fn spawn ( _read : impl Read , _write : impl Write , project_dir : & Path ) -> Result < ( ) , Error > {
8585 let ( tx, rx) = mpsc:: channel :: < Message > ( ) ;
8686 let cancel = RwLock :: new ( false ) ;
8787
@@ -100,7 +100,7 @@ pub async fn spawn(read: impl Read, write: impl Write, project_dir: &Path) -> Re
100100 ts:: init_repository ( "https://thunderstore.io" , None ) ;
101101
102102 loop {
103- if let Err ( e ) = stdin. read_line ( & mut line) {
103+ if let Err ( _ ) = stdin. read_line ( & mut line) {
104104 panic ! ( "" ) ;
105105 } ;
106106
@@ -172,12 +172,12 @@ async fn route_rq(rq: Request, rt: &mut Runtime) -> Result<(), Error> {
172172// }
173173// }
174174
175- fn respond_msg ( recv : Receiver < Message > , cancel : RwLock < bool > ) {
175+ fn respond_msg ( recv : Receiver < Message > , _cancel : RwLock < bool > ) {
176176 let mut stdout = io:: stdout ( ) ;
177177 while let Ok ( res) = recv. recv ( ) {
178178 let msg = serde_json:: to_string ( & res) ;
179- stdout. write_all ( msg. unwrap ( ) . as_bytes ( ) ) ;
180- stdout. write_all ( "\n " . as_bytes ( ) ) ;
179+ stdout. write_all ( msg. unwrap ( ) . as_bytes ( ) ) . unwrap ( ) ;
180+ stdout. write_all ( "\n " . as_bytes ( ) ) . unwrap ( ) ;
181181 }
182182}
183183
0 commit comments