forked from mirror/async-std
polish lib.rs examples
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
This commit is contained in:
parent
f611ceccc8
commit
2dfdc1c482
2 changed files with 49 additions and 9 deletions
50
src/lib.rs
50
src/lib.rs
|
@ -131,18 +131,56 @@
|
|||
//!
|
||||
//! # Examples
|
||||
//!
|
||||
//! Spawn a task and block the current thread on its result:
|
||||
//! All examples require the [`"attributes"` feature](#features) to be enabled.
|
||||
//! This feature is not enabled by default because it significantly impacts
|
||||
//! compile times. See [`task::block_on`] for an alternative way to start
|
||||
//! executing tasks.
|
||||
//!
|
||||
//! Call an async function from the main function:
|
||||
//!
|
||||
//! ```
|
||||
//! use async_std::task;
|
||||
//! async fn say_hello() {
|
||||
//! println!("Hello, world!");
|
||||
//! }
|
||||
//!
|
||||
//! fn main() {
|
||||
//! task::block_on(async {
|
||||
//! println!("Hello, world!");
|
||||
//! })
|
||||
//! #[async_std::main]
|
||||
//! async fn main() {
|
||||
//! say_hello().await;
|
||||
//! }
|
||||
//! ```
|
||||
//!
|
||||
//! Await two futures concurrently, and return a tuple of their output:
|
||||
//!
|
||||
//! ```
|
||||
//! #[async_std::main]
|
||||
//! async fn main() {
|
||||
//! let a = || async move { 1u8 };
|
||||
//! let b = || async move { 2u8 };
|
||||
//! assert_eq!(a.join(b).await, (1u8, 2u8))
|
||||
//! }
|
||||
//! ```
|
||||
//!
|
||||
//! Create a UDP server that echoes back each received message to the sender:
|
||||
//!
|
||||
//! ```no_run
|
||||
//! use async_std::net::UdpSocket;
|
||||
//!
|
||||
//! #[async_std::main]
|
||||
//! async fn main() -> std::io::Result<()> {
|
||||
//! let mut socket = UdpSocket::bind("127.0.0.1:8080")?;
|
||||
//! println!("Listening on {}", socket.local_addr()?);
|
||||
//!
|
||||
//! let mut buf = vec![0u8; 1024];
|
||||
//!
|
||||
//! loop {
|
||||
//! let (recv, peer) = socket.recv_from(&mut buf).await?;
|
||||
//! let sent = socket.send_to(&buf[..recv], &peer).await?;
|
||||
//! println!("Sent {} out of {} bytes to {}", sent, recv, peer);
|
||||
//! }
|
||||
//! }
|
||||
//! ```
|
||||
//! [`task::block_on`]: task/fn.block_on.html
|
||||
//!
|
||||
//! # Features
|
||||
//!
|
||||
//! Items marked with
|
||||
|
|
|
@ -28,9 +28,11 @@ use crate::task::{Context, Poll, Task, Waker};
|
|||
/// ```no_run
|
||||
/// use async_std::task;
|
||||
///
|
||||
/// task::block_on(async {
|
||||
/// println!("Hello, world!");
|
||||
/// })
|
||||
/// fn main() {
|
||||
/// task::block_on(async {
|
||||
/// println!("Hello, world!");
|
||||
/// })
|
||||
/// }
|
||||
/// ```
|
||||
pub fn block_on<F, T>(future: F) -> T
|
||||
where
|
||||
|
|
Loading…
Reference in a new issue