aboutsummaryrefslogtreecommitdiff
path: root/rtic-sync/src/channel.rs
diff options
context:
space:
mode:
authorYandrik <me@yandrik.dev>2023-03-15 20:17:26 +0100
committerYandrik <me@yandrik.dev>2023-03-15 20:17:26 +0100
commitef12ae6b04fa57371507e4ab49f49cb51c30ee4c (patch)
tree0040ac2adfde39ac64ad5c23a8c5a7d915fc1d63 /rtic-sync/src/channel.rs
parent60e5232ee90c8b05e92b1ffa16c2d770e726e2b1 (diff)
refactor: re-formatted files
Diffstat (limited to 'rtic-sync/src/channel.rs')
-rw-r--r--rtic-sync/src/channel.rs19
1 files changed, 10 insertions, 9 deletions
diff --git a/rtic-sync/src/channel.rs b/rtic-sync/src/channel.rs
index d0670c2..b7b5a48 100644
--- a/rtic-sync/src/channel.rs
+++ b/rtic-sync/src/channel.rs
@@ -103,7 +103,8 @@ impl<T, const N: usize> Channel<T, N> {
#[macro_export]
macro_rules! make_channel {
($type:path, $size:expr) => {{
- static mut CHANNEL: $crate::channel::Channel<$type, $size> = $crate::channel::Channel::new();
+ static mut CHANNEL: $crate::channel::Channel<$type, $size> =
+ $crate::channel::Channel::new();
// SAFETY: This is safe as we hide the static mut from others to access it.
// Only this point is where the mutable access happens.
@@ -125,8 +126,8 @@ pub enum TrySendError<T> {
}
impl<T> core::fmt::Debug for NoReceiver<T>
- where
- T: core::fmt::Debug,
+where
+ T: core::fmt::Debug,
{
fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
write!(f, "NoReceiver({:?})", self.0)
@@ -134,8 +135,8 @@ impl<T> core::fmt::Debug for NoReceiver<T>
}
impl<T> core::fmt::Debug for TrySendError<T>
- where
- T: core::fmt::Debug,
+where
+ T: core::fmt::Debug,
{
fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
match self {
@@ -146,8 +147,8 @@ impl<T> core::fmt::Debug for TrySendError<T>
}
impl<T> PartialEq for TrySendError<T>
- where
- T: PartialEq,
+where
+ T: PartialEq,
{
fn eq(&self, other: &Self) -> bool {
match (self, other) {
@@ -301,7 +302,7 @@ impl<'a, T, const N: usize> Sender<'a, T, N> {
Poll::Pending
}
})
- .await;
+ .await;
// Make sure the link is removed from the queue.
drop(dropper);
@@ -431,7 +432,7 @@ impl<'a, T, const N: usize> Receiver<'a, T, N> {
Poll::Pending
})
- .await
+ .await
}
/// Returns true if there are no `Sender`s.