mirror/rtic
1
0
Fork 0
mirror of https://github.com/rtic-rs/rtic.git synced 2024-11-26 05:29:38 +01:00
Code Issues Projects Releases Packages Wiki Activity

refactor: re-formatted channel.rs file

Browse source
This commit is contained in:
Yandrik 2023-03-15 15:18:31 +01:00
parent f2643a0076
commit 15b9db4c5d
1 changed files with 10 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
rtic-sync/src/channel.rs
View file

@ -38,6 +38,7 @@ pub struct Channel<T, const N: usize> {
} }
unsafe impl<T, const N: usize> Send for Channel<T, N> {} unsafe impl<T, const N: usize> Send for Channel<T, N> {}
unsafe impl<T, const N: usize> Sync for Channel<T, N> {} unsafe impl<T, const N: usize> Sync for Channel<T, N> {}
struct UnsafeAccess<'a, const N: usize> { struct UnsafeAccess<'a, const N: usize> {
@ -124,8 +125,8 @@ pub enum TrySendError<T> {
} }
impl<T> core::fmt::Debug for NoReceiver<T> impl<T> core::fmt::Debug for NoReceiver<T>
where where
T: core::fmt::Debug, T: core::fmt::Debug,
{ {
fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result { fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
write!(f, "NoReceiver({:?})", self.0) write!(f, "NoReceiver({:?})", self.0)
@ -133,8 +134,8 @@ where
} }
impl<T> core::fmt::Debug for TrySendError<T> impl<T> core::fmt::Debug for TrySendError<T>
where where
T: core::fmt::Debug, T: core::fmt::Debug,
{ {
fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result { fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
match self { match self {
@ -145,8 +146,8 @@ where
} }
impl<T> PartialEq for TrySendError<T> impl<T> PartialEq for TrySendError<T>
where where
T: PartialEq, T: PartialEq,
{ {
fn eq(&self, other: &Self) -> bool { fn eq(&self, other: &Self) -> bool {
match (self, other) { match (self, other) {
@ -176,6 +177,7 @@ impl LinkPtr {
} }
unsafe impl Send for LinkPtr {} unsafe impl Send for LinkPtr {}
unsafe impl Sync for LinkPtr {} unsafe impl Sync for LinkPtr {}
impl<'a, T, const N: usize> core::fmt::Debug for Sender<'a, T, N> { impl<'a, T, const N: usize> core::fmt::Debug for Sender<'a, T, N> {
@ -299,7 +301,7 @@ impl<'a, T, const N: usize> Sender<'a, T, N> {
Poll::Pending Poll::Pending
} }
}) })
.await; .await;
// Make sure the link is removed from the queue. // Make sure the link is removed from the queue.
drop(dropper); drop(dropper);
@ -429,7 +431,7 @@ impl<'a, T, const N: usize> Receiver<'a, T, N> {
Poll::Pending Poll::Pending
}) })
.await .await
} }
/// Returns true if there are no `Sender`s. /// Returns true if there are no `Sender`s.