Trait actix::fut::WrapStream

pub trait WrapStream<A>where
    A: Actor,{
    type Stream: ActorStream<Item = Self::Item, Error = Self::Error, Actor = A>;
    type Item;
    type Error;

    fn into_actor(self, a: &A) -> Self::Stream;
}

Helper trait that allows conversion of normal stream into ActorStream

Required Associated Types

type Stream: ActorStream<Item = Self::Item, Error = Self::Error, Actor = A>

The stream that this type can be converted into.

type Item

The item that the future may resolve with.

type Error

The error that the future may resolve with.

Required Methods

fn into_actor(self, a: &A) -> Self::Stream

Convert normal stream to a ActorStream

Implementors

impl<S: Stream, A: Actor> WrapStream<A> for S

type Stream = StreamWrap<S, A>

type Item = <S as Stream>::Item

type Error = <S as Stream>::Error