[−][src]Struct actix::AtomicResponse
A specialized actor future holder for atomic asynchronous message handling.
Intended be used when the future returned will need exclusive access Actor's internal state or context, e.g., it can yield at critical sessions. When the actor starts to process this future, it will not pull any other spawned futures until this one as been completed. Check ActorFuture for available methods for accessing Actor's internal state.
Note
The runtime itself is not blocked in the process, only the Actor, other futures, and therefore, other actors are still allowed to make progress when this AtomicResponse is used.
Examples
On the following example, the response to Msg
would always be 29
even if there are multiple Msg
sent to MyActor
.
impl Handler<Msg> for MyActor { type Result = AtomicResponse<Self, usize>; fn handle(&mut self, _: Msg, _: &mut Context<Self>) -> Self::Result { AtomicResponse::new(Box::pin( async {} .into_actor(self) .map(|_, this, _| { this.0 = 30; }) .then(|_, this, _| { delay_for(Duration::from_secs(3)).into_actor(this) }) .map(|_, this, _| { this.0 -= 1; this.0 }), )) } }
Implementations
impl<A, T> AtomicResponse<A, T>
[src]
pub fn new(fut: ResponseActFuture<A, T>) -> Self
[src]
Trait Implementations
impl<A, M, T: 'static> MessageResponse<A, M> for AtomicResponse<A, T> where
A: Actor,
M: Message<Result = T>,
A::Context: AsyncContext<A>,
[src]
A: Actor,
M: Message<Result = T>,
A::Context: AsyncContext<A>,
fn handle<R: ResponseChannel<M>>(self, ctx: &mut A::Context, tx: Option<R>)
[src]
Auto Trait Implementations
impl<A, T> !RefUnwindSafe for AtomicResponse<A, T>
impl<A, T> !Send for AtomicResponse<A, T>
impl<A, T> !Sync for AtomicResponse<A, T>
impl<A, T> Unpin for AtomicResponse<A, T>
impl<A, T> !UnwindSafe for AtomicResponse<A, T>
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,