Function actix::fut::stream::wrap_stream

pub fn wrap_stream<S, A>(stream: S) -> StreamWrap<S, A> where
    S: Stream,
    A: Actor, 

Converts normal stream into ActorStream