pub fn wrap_stream<S, A>(stream: S) -> StreamWrap<S, A>
where
    S: Stream,
    A: Actor,
{
    StreamWrap {
        stream,
        _act: PhantomData,
    }
}
/// Converts normal stream into `ActorStream`
Converts normal stream into `ActorStream`
Converts normal stream into ` ActorStream `
pub fn wrap_stream<S, A>(stream: S) -> StreamWrap<S, A>
where
    S: Stream,
    A: Actor,
{
    StreamWrap {
        stream,
        _act: PhantomData,
    }
}
pub fn wrap_stream < S , A > ( stream : S ) -> StreamWrap < S , A > where S : Stream , A : Actor , { StreamWrap { stream , _act : PhantomData , } }
Converts normal stream into `ActorStream`
Converts normal stream into ` ActorStream `
stream
S
stream
S