Merge pull request #4265 from cschuhen/rename-send-dynamic-receiver

Rename SendableDynamicReceiver to SendDynamicReceiver
This commit is contained in:
Ulf Lilleengen 2025-05-29 05:11:16 +00:00 committed by GitHub
commit b024d5e892
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

View File

@ -390,21 +390,21 @@ where
/// Receive-only access to a [`Channel`] without knowing channel size. /// Receive-only access to a [`Channel`] without knowing channel size.
/// This version can be sent between threads but can only be created if the underlying mutex is Sync. /// This version can be sent between threads but can only be created if the underlying mutex is Sync.
pub struct SendableDynamicReceiver<'ch, T> { pub struct SendDynamicReceiver<'ch, T> {
pub(crate) channel: &'ch dyn DynamicChannel<T>, pub(crate) channel: &'ch dyn DynamicChannel<T>,
} }
impl<'ch, T> Clone for SendableDynamicReceiver<'ch, T> { impl<'ch, T> Clone for SendDynamicReceiver<'ch, T> {
fn clone(&self) -> Self { fn clone(&self) -> Self {
*self *self
} }
} }
impl<'ch, T> Copy for SendableDynamicReceiver<'ch, T> {} impl<'ch, T> Copy for SendDynamicReceiver<'ch, T> {}
unsafe impl<'ch, T: Send> Send for SendableDynamicReceiver<'ch, T> {} unsafe impl<'ch, T: Send> Send for SendDynamicReceiver<'ch, T> {}
unsafe impl<'ch, T: Send> Sync for SendableDynamicReceiver<'ch, T> {} unsafe impl<'ch, T: Send> Sync for SendDynamicReceiver<'ch, T> {}
impl<'ch, T> SendableDynamicReceiver<'ch, T> { impl<'ch, T> SendDynamicReceiver<'ch, T> {
/// Receive the next value. /// Receive the next value.
/// ///
/// See [`Channel::receive()`]. /// See [`Channel::receive()`].
@ -434,7 +434,7 @@ impl<'ch, T> SendableDynamicReceiver<'ch, T> {
} }
} }
impl<'ch, M, T, const N: usize> From<Receiver<'ch, M, T, N>> for SendableDynamicReceiver<'ch, T> impl<'ch, M, T, const N: usize> From<Receiver<'ch, M, T, N>> for SendDynamicReceiver<'ch, T>
where where
M: RawMutex + Sync + Send, M: RawMutex + Sync + Send,
{ {