rdkafka: fix the error type of DeliveryFuture

Signed-off-by: Runji Wang <[email protected]>
madsim-rs · Sep 12, 2023 · 2211f81 · 2211f81
1 parent bb8f063
commit 2211f81
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/madsim-rdkafka/Cargo.toml b/madsim-rdkafka/Cargo.toml
@@ -15,6 +15,7 @@ license = "Apache-2.0"
 [target.'cfg(madsim)'.dependencies]
 async-channel = "1"
 async-trait = "0.1"
+futures-channel = "0.3.0"
 futures-util = "0.3"
 madsim = { version = "0.2.8" }
 serde = { version = "1", features = ["derive"] }

diff --git a/madsim-rdkafka/src/sim/producer/future_producer.rs b/madsim-rdkafka/src/sim/producer/future_producer.rs
@@ -7,8 +7,8 @@ use crate::{
     util::Timeout,
     ClientConfig, ClientContext,
 };
+use futures_channel::oneshot;
 use futures_util::FutureExt;
-use tokio::sync::oneshot;
 
 use std::future::Future;
 use std::pin::Pin;
@@ -218,7 +218,7 @@ pub struct DeliveryFuture {
 
 impl Future for DeliveryFuture {
     // the original crate returns `futures_channel::oneshot::Canceled`.
-    type Output = Result<OwnedDeliveryResult, oneshot::error::RecvError>;
+    type Output = Result<OwnedDeliveryResult, oneshot::Canceled>;
 
     fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
         self.rx.poll_unpin(cx)