smol-rs
/
event-listener
mirror of https://github.com/smol-rs/event-listener
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Remove extra comma from cfg (#82)

This commit is contained in:
Taiki Endo 2023-09-10 22:56:05 +09:00 committed by GitHub
parent d4c63e9e3c
commit 4965dddf8f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/lib.rs
View File

@ -94,7 +94,7 @@ use core::pin::Pin;
use core::ptr;
use core::task::{Context, Poll, Waker};
#[cfg(all(feature = "std", not(target_family = "wasm"),))]
#[cfg(all(feature = "std", not(target_family = "wasm")))]
use {
parking::{Parker, Unparker},
std::time::{Duration, Instant},
@ -720,7 +720,7 @@ impl<T> EventListener<T> {
/// // Receive the notification.
/// listener.as_mut().wait();
/// ```
#[cfg(all(feature = "std", not(target_family = "wasm"),))]
#[cfg(all(feature = "std", not(target_family = "wasm")))]
pub fn wait(self: Pin<&mut Self>) -> T {
self.listener().wait_internal(None).unwrap()
}
@ -741,7 +741,7 @@ impl<T> EventListener<T> {
/// // There are no notification so this times out.
/// assert!(listener.as_mut().wait_timeout(Duration::from_secs(1)).is_none());
/// ```
#[cfg(all(feature = "std", not(target_family = "wasm"),))]
#[cfg(all(feature = "std", not(target_family = "wasm")))]
pub fn wait_timeout(self: Pin<&mut Self>, timeout: Duration) -> Option<T> {
self.listener()
.wait_internal(Instant::now().checked_add(timeout))
@ -763,7 +763,7 @@ impl<T> EventListener<T> {
/// // There are no notification so this times out.
/// assert!(listener.as_mut().wait_deadline(Instant::now() + Duration::from_secs(1)).is_none());
/// ```
#[cfg(all(feature = "std", not(target_family = "wasm"),))]
#[cfg(all(feature = "std", not(target_family = "wasm")))]
pub fn wait_deadline(self: Pin<&mut Self>, deadline: Instant) -> Option<T> {
self.listener().wait_internal(Some(deadline))
}
@ -882,7 +882,7 @@ impl<T, B: Borrow<Inner<T>> + Unpin> Listener<T, B> {
}
/// Wait until the provided deadline.
#[cfg(all(feature = "std", not(target_family = "wasm"),))]
#[cfg(all(feature = "std", not(target_family = "wasm")))]
fn wait_internal(mut self: Pin<&mut Self>, deadline: Option<Instant>) -> Option<T> {
use std::cell::RefCell;
@ -916,7 +916,7 @@ impl<T, B: Borrow<Inner<T>> + Unpin> Listener<T, B> {
}
/// Wait until the provided deadline using the specified parker/unparker pair.
#[cfg(all(feature = "std", not(target_family = "wasm"),))]
#[cfg(all(feature = "std", not(target_family = "wasm")))]
fn wait_with_parker(
self: Pin<&mut Self>,
deadline: Option<Instant>,
@ -1078,7 +1078,7 @@ enum Task {
Waker(Waker),
/// An unparker that wakes up a thread.
#[cfg(all(feature = "std", not(target_family = "wasm"),))]
#[cfg(all(feature = "std", not(target_family = "wasm")))]
Unparker(Unparker),
}
@ -1086,7 +1086,7 @@ impl Task {
fn as_task_ref(&self) -> TaskRef<'_> {
match self {
Self::Waker(waker) => TaskRef::Waker(waker),
#[cfg(all(feature = "std", not(target_family = "wasm"),))]
#[cfg(all(feature = "std", not(target_family = "wasm")))]
Self::Unparker(unparker) => TaskRef::Unparker(unparker),
}
}
@ -1094,7 +1094,7 @@ impl Task {
fn wake(self) {
match self {
Self::Waker(waker) => waker.wake(),
#[cfg(all(feature = "std", not(target_family = "wasm"),))]
#[cfg(all(feature = "std", not(target_family = "wasm")))]
Self::Unparker(unparker) => {
unparker.unpark();
}
@ -1115,7 +1115,7 @@ enum TaskRef<'a> {
Waker(&'a Waker),
/// An unparker that wakes up a thread.
#[cfg(all(feature = "std", not(target_family = "wasm"),))]
#[cfg(all(feature = "std", not(target_family = "wasm")))]
Unparker(&'a Unparker),
}
@ -1125,7 +1125,7 @@ impl TaskRef<'_> {
fn will_wake(self, other: Self) -> bool {
match (self, other) {
(Self::Waker(a), Self::Waker(b)) => a.will_wake(b),
#[cfg(all(feature = "std", not(target_family = "wasm"),))]
#[cfg(all(feature = "std", not(target_family = "wasm")))]
(Self::Unparker(_), Self::Unparker(_)) => {
// TODO: Use unreleased will_unpark API.
false
@ -1138,7 +1138,7 @@ impl TaskRef<'_> {
fn into_task(self) -> Task {
match self {
Self::Waker(waker) => Task::Waker(waker.clone()),
#[cfg(all(feature = "std", not(target_family = "wasm"),))]
#[cfg(all(feature = "std", not(target_family = "wasm")))]
Self::Unparker(unparker) => Task::Unparker(unparker.clone()),
}
}