@@ -222,10 +222,13 @@ impl Transport {
222222 loop {
223223 match Self::recv_server_message(&mut server_stdout, &mut recv_buffer).await {
224224 Ok(msg) => {
225− transport
226− .process_server_message(&client_tx, msg)
227− .await
228− .unwrap();
225+ match transport.process_server_message(&client_tx, msg).await {
226+ Ok(_) => {}
227+ Err(err) => {
228+ error!("err: <- {:?}", err);
229+ break;
230+ }
231+ };
229232 }
230233 Err(err) => {
231234 error!("err: <- {:?}", err);
@@ -254,10 +257,15 @@ impl Transport {
254257 mut client_rx: UnboundedReceiver<Payload>,
255258 ) {
256259 while let Some(msg) = client_rx.recv().await {
257− transport
260+ match transport
258261 .send_payload_to_server(&mut server_stdin, msg)
259262 .await
260− .unwrap()
263+ {
264+ Ok(_) => {}
265+ Err(err) => {
266+ error!("err: <- {:?}", err);
267+ }
268+ }
261269 }
262270 }
263271}