Skip to content

Commit

Permalink
Use the unstable #[doc(cfg)] to document the tokio feature
Browse files Browse the repository at this point in the history
  • Loading branch information
asomers committed Jan 30, 2019
1 parent 627b51a commit 8656665
Show file tree
Hide file tree
Showing 5 changed files with 19 additions and 24 deletions.
4 changes: 4 additions & 0 deletions .cirrus.yml
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,10 @@ test_task:
- cargo test
- fi
- cargo test --no-default-features
doc_script:
- if rustc --version | grep -q nightly; then
- cargo doc --all-features --no-deps
- fi
before_cache_script: rm -rf $CARGO_HOME/registry/index

codecov_task:
Expand Down
1 change: 1 addition & 0 deletions Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,7 @@ autotests = false

[features]
default = ["tokio"]
nightly-docs = []
tokio = ["tokio-current-thread", "tokio-executor"]

[dependencies]
Expand Down
2 changes: 2 additions & 0 deletions src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,8 @@
//! [`Futures`]: https://github.com/rust-lang-nursery/futures-rs
//! [`Tokio`]: https:/tokio.rs

#![cfg_attr(feature = "nightly-docs", feature(doc_cfg))]

extern crate futures;
#[cfg(feature = "tokio")] extern crate tokio_current_thread;
#[cfg(feature = "tokio")] extern crate tokio_executor;
Expand Down
12 changes: 4 additions & 8 deletions src/mutex.rs
Original file line number Diff line number Diff line change
Expand Up @@ -295,9 +295,6 @@ impl<T: 'static + ?Sized> Mutex<T> {
/// separate task. Returns a `Future` containing the result of the
/// computation.
///
/// *This method requires Futures-locks to be build with the `"tokio"`
/// feature.*
///
/// When using Tokio, this method will often hold the `Mutex` for less time
/// than chaining a computation to [`lock`](#method.lock). The reason is
/// that Tokio polls all tasks promptly upon notification. However, Tokio
Expand Down Expand Up @@ -328,7 +325,8 @@ impl<T: 'static + ?Sized> Mutex<T> {
/// assert_eq!(mtx.try_unwrap().unwrap(), 5);
/// # }
/// ```
#[cfg(feature = "tokio")]
#[cfg(any(feature = "tokio", rustdoc))]
#[cfg_attr(feature = "nightly-docs", doc(cfg(feature = "tokio")))]
pub fn with<F, B, R, E>(&self, f: F)
-> Result<impl Future<Item = R, Error = E>, SpawnError>
where F: FnOnce(MutexGuard<T>) -> B + Send + 'static,
Expand Down Expand Up @@ -357,9 +355,6 @@ impl<T: 'static + ?Sized> Mutex<T> {
/// Like [`with`](#method.with) but for Futures that aren't `Send`.
/// Spawns a new task on a single-threaded Runtime to complete the Future.
///
/// *This method requires Futures-locks to be build with the `"tokio"`
/// feature.*
///
/// # Examples
///
/// ```
Expand All @@ -384,7 +379,8 @@ impl<T: 'static + ?Sized> Mutex<T> {
/// assert_eq!(*mtx.try_unwrap().unwrap(), 5);
/// # }
/// ```
#[cfg(feature = "tokio")]
#[cfg(any(feature = "tokio", rustdoc))]
#[cfg_attr(feature = "nightly-docs", doc(cfg(feature = "tokio")))]
pub fn with_local<F, B, R, E>(&self, f: F)
-> Result<impl Future<Item = R, Error = E>, SpawnError>
where F: FnOnce(MutexGuard<T>) -> B + 'static,
Expand Down
24 changes: 8 additions & 16 deletions src/rwlock.rs
Original file line number Diff line number Diff line change
Expand Up @@ -489,9 +489,6 @@ impl<T: 'static + ?Sized> RwLock<T> {
/// guarded value in a separate task. Returns a `Future` containing the
/// result of the computation.
///
/// *This method requires Futures-locks to be build with the `"tokio"`
/// feature.*
///
/// When using Tokio, this method will often hold the `RwLock` for less time
/// than chaining a computation to [`read`](#method.read). The reason is
/// that Tokio polls all tasks promptly upon notification. However, Tokio
Expand Down Expand Up @@ -520,7 +517,8 @@ impl<T: 'static + ?Sized> RwLock<T> {
/// assert_eq!(r, Ok(5));
/// # }
/// ```
#[cfg(feature = "tokio")]
#[cfg(any(feature = "tokio", rustdoc))]
#[cfg_attr(feature = "nightly-docs", doc(cfg(feature = "tokio")))]
pub fn with_read<F, B, R, E>(&self, f: F)
-> Result<impl Future<Item = R, Error = E>, SpawnError>
where F: FnOnce(RwLockReadGuard<T>) -> B + Send + 'static,
Expand Down Expand Up @@ -550,9 +548,6 @@ impl<T: 'static + ?Sized> RwLock<T> {
/// `Send`. Spawns a new task on a single-threaded Runtime to complete the
/// Future.
///
/// *This method requires Futures-locks to be build with the `"tokio"`
/// feature.*
///
/// # Examples
///
/// ```
Expand All @@ -575,7 +570,8 @@ impl<T: 'static + ?Sized> RwLock<T> {
/// assert_eq!(r, Ok(5));
/// # }
/// ```
#[cfg(feature = "tokio")]
#[cfg(any(feature = "tokio", rustdoc))]
#[cfg_attr(feature = "nightly-docs", doc(cfg(feature = "tokio")))]
pub fn with_read_local<F, B, R, E>(&self, f: F)
-> Result<impl Future<Item = R, Error = E>, SpawnError>
where F: FnOnce(RwLockReadGuard<T>) -> B + 'static,
Expand Down Expand Up @@ -604,9 +600,6 @@ impl<T: 'static + ?Sized> RwLock<T> {
/// guarded value in a separate task. Returns a `Future` containing the
/// result of the computation.
///
/// *This method requires Futures-locks to be build with the `"tokio"`
/// feature.*
///
/// When using Tokio, this method will often hold the `RwLock` for less time
/// than chaining a computation to [`write`](#method.write). The reason is
/// that Tokio polls all tasks promptly upon notification. However, Tokio
Expand Down Expand Up @@ -637,7 +630,8 @@ impl<T: 'static + ?Sized> RwLock<T> {
/// assert_eq!(rwlock.try_unwrap().unwrap(), 5);
/// # }
/// ```
#[cfg(feature = "tokio")]
#[cfg(any(feature = "tokio", rustdoc))]
#[cfg_attr(feature = "nightly-docs", doc(cfg(feature = "tokio")))]
pub fn with_write<F, B, R, E>(&self, f: F)
-> Result<impl Future<Item = R, Error = E>, SpawnError>
where F: FnOnce(RwLockWriteGuard<T>) -> B + Send + 'static,
Expand Down Expand Up @@ -667,9 +661,6 @@ impl<T: 'static + ?Sized> RwLock<T> {
/// `Send`. Spawns a new task on a single-threaded Runtime to complete the
/// Future.
///
/// *This method requires Futures-locks to be build with the `"tokio"`
/// feature.*
///
/// # Examples
///
/// ```
Expand All @@ -694,7 +685,8 @@ impl<T: 'static + ?Sized> RwLock<T> {
/// assert_eq!(*rwlock.try_unwrap().unwrap(), 5);
/// # }
/// ```
#[cfg(feature = "tokio")]
#[cfg(any(feature = "tokio", rustdoc))]
#[cfg_attr(feature = "nightly-docs", doc(cfg(feature = "tokio")))]
pub fn with_write_local<F, B, R, E>(&self, f: F)
-> Result<impl Future<Item = R, Error = E>, SpawnError>
where F: FnOnce(RwLockWriteGuard<T>) -> B + 'static,
Expand Down

0 comments on commit 8656665

Please sign in to comment.