diff --git a/fe2o3-amqp/src/connection/mod.rs b/fe2o3-amqp/src/connection/mod.rs index 4193c1f2..37f3ae25 100644 --- a/fe2o3-amqp/src/connection/mod.rs +++ b/fe2o3-amqp/src/connection/mod.rs @@ -56,6 +56,10 @@ type SessionRelay = Arc>; /// A handle to the [`Connection`] event loop. /// /// Dropping the handle will also stop the [`Connection`] event loop. +/// +/// # Generic Parameters +/// +/// - `R`: The type of the session listener. This will be `()` on the client side. #[allow(dead_code)] pub struct ConnectionHandle { /// Only change this value in `on_close` method diff --git a/fe2o3-amqp/src/link/mod.rs b/fe2o3-amqp/src/link/mod.rs index b88c6aeb..f0c7216b 100644 --- a/fe2o3-amqp/src/link/mod.rs +++ b/fe2o3-amqp/src/link/mod.rs @@ -117,12 +117,6 @@ pub mod role { } } -// pub(crate) struct Transferable { -// input_handle: InputHandle, -// transfer: Transfer, -// payload: Payload, -// } - pub(crate) enum SenderAttachExchange { Complete, IncompleteUnsettled(Vec<(DeliveryTag, ResumingDelivery)>), diff --git a/fe2o3-amqp/src/session/mod.rs b/fe2o3-amqp/src/session/mod.rs index 958930ae..3105e93e 100644 --- a/fe2o3-amqp/src/session/mod.rs +++ b/fe2o3-amqp/src/session/mod.rs @@ -54,6 +54,10 @@ pub const DEFAULT_WINDOW: Uint = 2048; /// A handle to the [`Session`] event loop /// /// Dropping the handle will also stop the [`Session`] event loop +/// +/// # Generic Parameters +/// +/// - `R`: The type of the listener for the link. This will be `()` on the client side. #[allow(dead_code)] pub struct SessionHandle { /// This value should only be changed in the `on_end` method