Trait wsrpc::WebsocketService

pub trait WebsocketService<Ctx: Clone> {
    fn serve_ws(
        &self, 
        ctx: Ctx, 
        raw_req: Value, 
        service_id: &str
    ) -> BoxStream<'static, Result<Box<RawValue>, ErrorKind>>;
}

Required methods

fn serve_ws(
    &self,
    ctx: Ctx,
    raw_req: Value,
    service_id: &str
) -> BoxStream<'static, Result<Box<RawValue>, ErrorKind>>

Implementors

impl<Req, Resp, Ctx, S> WebsocketService<Ctx> for S where
    S: Service<Req = Req, Resp = Resp, Ctx = Ctx>,
    Req: DeserializeOwned,
    Resp: Serialize + 'static,
    Ctx: Clone,