update amq-protocol

Author: Keruspe

Cargo.lock

@@ -39,7 +39,7 @@ rustls--aws_lc_rs         = ["amq-protocol/rustls--aws_lc_rs"] # default, but do
 rustls--ring              = ["amq-protocol/rustls--ring"] # more compatible, (e.g., easily builds on Windows)
 
 [build-dependencies.amq-protocol-codegen]
-version = "^10.0.0-beta.7"
+version = "^10.0.0-rc.1"
 optional = true
 
 [build-dependencies.serde_json]
@@ -53,11 +53,11 @@ futures-core = "^0.3"
 futures-io = "^0.3"
 
 [dependencies.amq-protocol]
-version = "^10.0.0-beta.7"
+version = "^10.0.0-rc.1"
 default-features = false
 
 [dependencies.async-rs]
-version = "^0.7"
+version = "^0.8"
 default-features = false
 
 [dependencies.backon]

Cargo.toml

@@ -18,10 +18,11 @@ use backon::{ExponentialBuilder, Retryable};
 use futures_io::{AsyncRead, AsyncWrite};
 use std::{
     collections::VecDeque,
+    future::Future,
     io,
     pin::Pin,
     sync::Arc,
-    task::{Context, Poll},
+    task::{self, Context, Poll},
     thread::Builder as ThreadBuilder,
     time::Duration,
 };
@@ -578,9 +579,21 @@ impl<
 struct RuntimeSleeper<RK: RuntimeKit + Clone + Send + 'static>(Runtime<RK>);
 
 impl<RK: RuntimeKit + Clone + Send + 'static> backon::Sleeper for RuntimeSleeper<RK> {
-    type Sleep = Pin<Box<dyn Future<Output = ()> + Send + 'static>>; // FIXME
+    type Sleep = UnitFuture<<RK as Reactor>::Sleep>;
 
     fn sleep(&self, dur: Duration) -> Self::Sleep {
-        Box::pin(self.0.sleep(dur))
+        UnitFuture(Box::pin(self.0.sleep(dur)))
+    }
+}
+
+// FIXME: drop UnitFuture when backon supports non-unit futures
+struct UnitFuture<F: Future>(Pin<Box<F>>);
+
+impl<F: Future> Future for UnitFuture<F> {
+    type Output = ();
+
+    fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
+        task::ready!(self.0.as_mut().poll(cx));
+        Poll::Ready(())
     }
 }