[−][src]Trait actix_async_await::AsyncContextExt

pub trait AsyncContextExt<A>: AsyncContext<A> where
    A: Actor<Context = Self>, {
    fn add_stream_03<S>(&mut self, fut: S) -> SpawnHandle
    where
        S: TryStream + Unpin + 'static,
        A: StreamHandler<S::Ok, S::Error>,
    { ... }

    fn add_message_stream_03<S>(&mut self, fut: S)
    where
        S: Stream + Unpin + 'static,
        S::Item: Message,
        A: Handler<S::Item>,
    { ... }
}

Provided methods

fn add_stream_03<S>(&mut self, fut: S) -> SpawnHandle where
    S: TryStream + Unpin + 'static,
    A: StreamHandler<S::Ok, S::Error>, 

This method register stream to an actor context and allows to handle Stream in similar way as normal actor messages.

fn add_message_stream_03<S>(&mut self, fut: S) where
    S: Stream + Unpin + 'static,
    S::Item: Message,
    A: Handler<S::Item>, 

Loading content...

Implementors

impl<A, C> AsyncContextExt<A> for C where
    A: Actor<Context = C>,
    C: AsyncContext<A>, [src]

fn add_stream_03<S>(&mut self, fut: S) -> SpawnHandle where
    S: TryStream + Unpin + 'static,
    A: StreamHandler<S::Ok, S::Error>, [src]

fn add_message_stream_03<S>(&mut self, fut: S) where
    S: Stream + Unpin + 'static,
    S::Item: Message,
    A: Handler<S::Item>, [src]

Loading content...