actix::fut::stream

Function wrap_stream

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

Converts normal stream into ActorStream