Struct ntex::rt::Arbiter [−][src]
pub struct Arbiter { /* fields omitted */ }
Expand description
Arbiters provide an asynchronous execution environment for actors, functions and futures. When an Arbiter is created, it spawns a new OS thread, and hosts an event loop. Some Arbiter functions execute on the current thread.
Implementations
impl Arbiter
[src]
impl Arbiter
[src]pub fn current() -> Arbiter
[src]
pub fn current() -> Arbiter
[src]Returns the current thread’s arbiter’s address. If no Arbiter is present, then this function will panic!
pub fn new() -> Arbiter
[src]
pub fn new() -> Arbiter
[src]Spawn new thread and run event loop in spawned thread. Returns address of newly created arbiter.
pub fn spawn<F>(&self, future: F) where
F: Future<Output = ()> + Send + Unpin + 'static,
[src]
pub fn spawn<F>(&self, future: F) where
F: Future<Output = ()> + Send + Unpin + 'static,
[src]Send a future to the Arbiter’s thread, and spawn it.
pub fn exec<F, R>(&self, f: F) -> impl Future<Output = Result<R, RecvError>> where
F: FnOnce() -> R + Send + 'static,
R: Send + 'static,
[src]
pub fn exec<F, R>(&self, f: F) -> impl Future<Output = Result<R, RecvError>> where
F: FnOnce() -> R + Send + 'static,
R: Send + 'static,
[src]Send a function to the Arbiter’s thread. This function will be executed asynchronously. A future is created, and when resolved will contain the result of the function sent to the Arbiters thread.
pub fn exec_fn<F>(&self, f: F) where
F: FnOnce() + Send + 'static,
[src]
pub fn exec_fn<F>(&self, f: F) where
F: FnOnce() + Send + 'static,
[src]Send a function to the Arbiter’s thread, and execute it. Any result from the function is discarded.
pub fn contains_item<T>() -> bool where
T: 'static,
[src]
pub fn contains_item<T>() -> bool where
T: 'static,
[src]Check if arbiter storage contains item
pub fn get_item<T, F, R>(f: F) -> R where
T: 'static,
F: FnMut(&T) -> R,
[src]
pub fn get_item<T, F, R>(f: F) -> R where
T: 'static,
F: FnMut(&T) -> R,
[src]Get a reference to a type previously inserted on this arbiter’s storage.
Panics is item is not inserted
pub fn get_mut_item<T, F, R>(f: F) -> R where
T: 'static,
F: FnMut(&mut T) -> R,
[src]
pub fn get_mut_item<T, F, R>(f: F) -> R where
T: 'static,
F: FnMut(&mut T) -> R,
[src]Get a mutable reference to a type previously inserted on this arbiter’s storage.
Panics is item is not inserted
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for Arbiter
impl Send for Arbiter
impl Sync for Arbiter
impl Unpin for Arbiter
impl !UnwindSafe for Arbiter
Blanket Implementations
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]pub fn borrow_mut(&mut self) -> &mut T
[src]
pub fn borrow_mut(&mut self) -> &mut T
[src]Mutably borrows from an owned value. Read more
impl<T> Instrument for T
[src]
impl<T> Instrument for T
[src]fn instrument(self, span: Span) -> Instrumented<Self>
[src]
fn instrument(self, span: Span) -> Instrumented<Self>
[src]Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
fn in_current_span(self) -> Instrumented<Self>
[src]
fn in_current_span(self) -> Instrumented<Self>
[src]impl<T> Same<T> for T
impl<T> Same<T> for T
type Output = T
type Output = T
Should always be Self
impl<T> ToOwned for T where
T: Clone,
[src]
impl<T> ToOwned for T where
T: Clone,
[src]type Owned = T
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T
[src]
pub fn to_owned(&self) -> T
[src]Creates owned data from borrowed data, usually by cloning. Read more
pub fn clone_into(&self, target: &mut T)
[src]
pub fn clone_into(&self, target: &mut T)
[src]🔬 This is a nightly-only experimental API. (toowned_clone_into
)
recently added
Uses borrowed data to replace owned data, usually by cloning. Read more