pub fn create<S>(actor: A, stream: S) -> impl Stream<Item = Result<Bytes, Error>>
    where
        A: StreamHandler<Result<Message, ProtocolError>>,
        S: Stream<Item = Result<Bytes, PayloadError>> + 'static,
    {
        let (_, stream) = WebsocketContext::create_with_addr(actor, stream);
        stream
    }
/// Create a new Websocket context from a request and an actor
Create a new Websocket context from a request and an actor
Create a new Websocket context from a request and an actor
pub fn create<S>(actor: A, stream: S) -> impl Stream<Item = Result<Bytes, Error>>
    where
        A: StreamHandler<Result<Message, ProtocolError>>,
        S: Stream<Item = Result<Bytes, PayloadError>> + 'static,
    {
        let (_, stream) = WebsocketContext::create_with_addr(actor, stream);
        stream
    }
pub fn create < S > ( actor : A , stream : S ) -> impl Stream < Item = Result < Bytes , Error > > where A : StreamHandler < Result < Message , ProtocolError > > , S : Stream < Item = Result < Bytes , PayloadError > > + ' static , { let ( _ , stream ) = WebsocketContext :: create_with_addr ( actor , stream ) ; stream }
Create a new Websocket context from a request and an actor
Create a new Websocket context from a request and an actor
actor
A
stream
S