Merge pull request #50 from drogue-iot/propagate-error-kind

Propagate the eio ErrorKind

src/lib.rs

@@ -37,13 +37,17 @@ pub enum Error {
  AlreadySent,
  /// An invalid number of bytes were written to request body
  IncorrectBodyWritten,
- /// The underlying connection was closed
- ConnectionClosed,
+ /// The underlying connection was closed while being used
+ ConnectionAborted,
 }
 
 impl embedded_io::Error for Error {
  fn kind(&self) -> embedded_io::ErrorKind {
- embedded_io::ErrorKind::Other
+ match self {
+ Error::Network(kind) => *kind,
+ Error::ConnectionAborted => embedded_io::ErrorKind::ConnectionAborted,
+ _ => embedded_io::ErrorKind::Other,
+ }
  }
 }
 
@@ -56,7 +60,7 @@ impl From<embedded_io::ErrorKind> for Error {
 impl<E: embedded_io::Error> From<ReadExactError<E>> for Error {
  fn from(value: ReadExactError<E>) -> Self {
  match value {
- ReadExactError::UnexpectedEof => Error::ConnectionClosed,
+ ReadExactError::UnexpectedEof => Error::ConnectionAborted,
  ReadExactError::Other(e) => Error::Network(e.kind()),
  }
  }

src/response.rs

@@ -51,7 +51,7 @@ where
  })?;
 
  if n == 0 {
- return Err(Error::ConnectionClosed);
+ return Err(Error::ConnectionAborted);
  }
 
  pos += n;
@@ -413,7 +413,7 @@ where
  .map(|data| &data[..data.len().min(self.remaining)])?;
 
  if loaded.is_empty() {
- return Err(Error::ConnectionClosed);
+ return Err(Error::ConnectionAborted);
  }
 
  Ok(loaded)