1
0
mirror of https://github.com/fafhrd91/actix-net synced 2025-01-31 12:42:09 +01:00

Merge branch 'master' of github.com:actix/actix-net

This commit is contained in:
Nikolay Kim 2020-01-14 00:42:29 -08:00
commit 2f89483635
2 changed files with 4 additions and 4 deletions

View File

@ -42,8 +42,8 @@ impl fmt::Debug for ArbiterCommand {
#[derive(Debug)] #[derive(Debug)]
/// Arbiters provide an asynchronous execution environment for actors, functions /// Arbiters provide an asynchronous execution environment for actors, functions
/// and futures. When an Arbiter is created, they spawn a new OS thread, and /// and futures. When an Arbiter is created, it spawns a new OS thread, and
/// host an event loop. Some Arbiter functions execute on the current thread. /// hosts an event loop. Some Arbiter functions execute on the current thread.
pub struct Arbiter { pub struct Arbiter {
sender: UnboundedSender<ArbiterCommand>, sender: UnboundedSender<ArbiterCommand>,
thread_handle: Option<thread::JoinHandle<()>>, thread_handle: Option<thread::JoinHandle<()>>,

View File

@ -57,7 +57,7 @@ pub use self::transform::{apply, Transform};
/// ///
/// fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { ... } /// fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { ... }
/// ///
/// fn call(&mut self) -> Self::Future { ... } /// fn call(&mut self, req: Self::Request) -> Self::Future { ... }
/// } /// }
/// ``` /// ```
/// ///
@ -82,7 +82,7 @@ pub trait Service {
/// Returns `Ready` when the service is able to process requests. /// Returns `Ready` when the service is able to process requests.
/// ///
/// If the service is at capacity, then `NotReady` is returned and the task /// If the service is at capacity, then `Pending` is returned and the task
/// is notified when the service becomes ready again. This function is /// is notified when the service becomes ready again. This function is
/// expected to be called while on a task. /// expected to be called while on a task.
/// ///