Handle codec errors in REQ socket recv (#172)

zeromq · Nov 1, 2023 · 59be7a0 · 59be7a0
1 parent 8de2dbe
commit 59be7a0
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/req.rs b/src/req.rs
@@ -85,7 +85,8 @@ impl SocketRecv for ReqSocket {
  assert!(m.pop_front().unwrap().is_empty()); // Ensure that we have delimeter as first part
  Ok(m)
  }
- Some(_) => todo!(),
+ Some(Ok(_)) => todo!(),
+ Some(Err(error)) => Err(error.into()),
  None => Err(ZmqError::NoMessage),
  }
  } else {