From 51c4b72626a06d427642e69996f5870efeb40a1b Mon Sep 17 00:00:00 2001
From: minish <minish@riseup.net>
Date: Sat, 8 Jun 2024 02:03:51 -0400
Subject: [PATCH] v0.2.2 - fix #3

---
 Cargo.lock    | 2 +-
 Cargo.toml    | 2 +-
 src/engine.rs | 8 ++++----
 3 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/Cargo.lock b/Cargo.lock
index 3fb8aa9..178ee26 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -246,7 +246,7 @@ checksum = "cf4b9d6a944f767f8e5e0db018570623c85f3d925ac718db4e06d0187adb21c1"
 
 [[package]]
 name = "breeze"
-version = "0.2.1"
+version = "0.2.2"
 dependencies = [
  "anyhow",
  "async-recursion",
diff --git a/Cargo.toml b/Cargo.toml
index 6ec018b..44267df 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "breeze"
-version = "0.2.1"
+version = "0.2.2"
 edition = "2021"
 
 [dependencies]
diff --git a/src/engine.rs b/src/engine.rs
index e2e181f..baac692 100644
--- a/src/engine.rs
+++ b/src/engine.rs
@@ -170,7 +170,7 @@ impl Engine {
         mut stream: BodyDataStream,
         lifetime: Option<Duration>,
         keep_exif: bool,
-    ) -> Result<(), axum::Error> {
+    ) -> Result<(), anyhow::Error> {
         // if we're using cache, make some space to store the upload in
         let mut data = if use_cache {
             BytesMut::with_capacity(provided_len)
@@ -208,7 +208,7 @@ impl Engine {
             if !coalesce_and_strip {
                 if let Some(ref tx) = tx {
                     debug!("sending chunk to i/o task");
-                    let _ = tx.send(chunk.clone()).await;
+                    tx.send(chunk.clone()).await?;
                 }
             }
 
@@ -250,7 +250,7 @@ impl Engine {
             // send what we did over to the i/o task, all in one chunk
             if let Some(ref tx) = tx {
                 debug!("sending filled buffer to i/o task");
-                let _ = tx.send(data.clone()).await;
+                tx.send(data.clone()).await?;
             }
 
             data
@@ -284,7 +284,7 @@ impl Engine {
         stream: BodyDataStream,
         lifetime: Option<Duration>,
         keep_exif: bool,
-    ) -> Result<ProcessOutcome, axum::Error> {
+    ) -> Result<ProcessOutcome, anyhow::Error> {
         // if the upload size is smaller than the specified maximum, we use the cache!
         let use_cache: bool = self.cache.will_use(provided_len);