pub(crate) fn package(message: M) -> (Self, AcknowledgmentReceiver<R>) {
        let (sender, receiver) = tokio::sync::oneshot::channel();
        (
            Self {
                message,
                notifier: sender,
            },
            AcknowledgmentReceiver { receiver },
        )
    }
/// Create a new message and return it along with the AcknowledgmentReceiver that will
/// be notified when the message is received or when it is dropped.
Create a new message and return it along with the AcknowledgmentReceiver that will
be notified when the message is received or when it is dropped.
Create a new message and return it along with the AcknowledgmentReceiver that will be notified when the message is received or when it is dropped .
pub(crate) fn package(message: M) -> (Self, AcknowledgmentReceiver<R>) {
        let (sender, receiver) = tokio::sync::oneshot::channel();
        (
            Self {
                message,
                notifier: sender,
            },
            AcknowledgmentReceiver { receiver },
        )
    }
pub ( crate ) fn package ( message : M ) -> ( Self , AcknowledgmentReceiver < R > ) { let ( sender , receiver ) = tokio :: sync :: oneshot :: channel ( ) ; ( Self { message , notifier : sender , } , AcknowledgmentReceiver { receiver } , ) }
Create a new message and return it along with the AcknowledgmentReceiver that will
be notified when the message is received or when it is dropped.
Create a new message and return it along with the AcknowledgmentReceiver that will be notified when the message is received or when it is dropped .
message
M
message
M