@@ -222,10 +222,13 @@ impl Transport {
223 match Self::recv_server_message(&mut server_stdout, &mut recv_buffer).await {
223 match Self::recv_server_message(&mut server_stdout, &mut recv_buffer).await {
224 Ok(msg) => {
224 Ok(msg) => {
226− .process_server_message(&client_tx, msg)
225+ match transport.process_server_message(&client_tx, msg).await {
227− .await
226+ Ok(_) => {}
228− .unwrap();
227+ Err(err) => {
228+ error!("err: <- {:?}", err);
230 Err(err) => {
233 Err(err) => {
231 error!("err: <- {:?}", err);
234 error!("err: <- {:?}", err);
@@ -254,10 +257,15 @@ impl Transport {
254 mut client_rx: UnboundedReceiver<Payload>,
257 mut client_rx: UnboundedReceiver<Payload>,
256 while let Some(msg) = client_rx.recv().await {
259 while let Some(msg) = client_rx.recv().await {
257− transport
260+ match transport
258 .send_payload_to_server(&mut server_stdin, msg)
261 .send_payload_to_server(&mut server_stdin, msg)
266+ error!("err: <- {:?}", err);