pub fn start<A, T>(actor: A, req: &HttpRequest, stream: T) -> Result<HttpResponse, Error>
where
    A: Actor<Context = WebsocketContext<A>> + StreamHandler<Result<Message, ProtocolError>>,
    T: Stream<Item = Result<Bytes, PayloadError>> + 'static,
{
    let mut res = handshake(req)?;
    Ok(res.streaming(WebsocketContext::create(actor, stream)))
}
/// Perform WebSocket handshake and start actor.
Perform WebSocket handshake and start actor.
Perform WebSocket handshake and start actor .
pub fn start<A, T>(actor: A, req: &HttpRequest, stream: T) -> Result<HttpResponse, Error>
where
    A: Actor<Context = WebsocketContext<A>> + StreamHandler<Result<Message, ProtocolError>>,
    T: Stream<Item = Result<Bytes, PayloadError>> + 'static,
{
    let mut res = handshake(req)?;
    Ok(res.streaming(WebsocketContext::create(actor, stream)))
}
pub fn start < A , T > ( actor : A , req : & HttpRequest , stream : T ) -> Result < HttpResponse , Error > where A : Actor < Context = WebsocketContext < A > > + StreamHandler < Result < Message , ProtocolError > > , T : Stream < Item = Result < Bytes , PayloadError > > + ' static , { let mut res = handshake ( req ) ? ; Ok ( res . streaming ( WebsocketContext :: create ( actor , stream ) ) ) }
Perform WebSocket handshake and start actor.
Perform WebSocket handshake and start actor .
actor
A
req
&HttpRequest
stream
T
actor
A
req
&HttpRequest
stream
T