Struct engine_io_server::server::Server

pub struct Server<A: 'static + Adapter> { /* fields omitted */ }

Implementations

impl<A: 'static + Adapter> Server<A>

pub fn new(options: ServerOptions) -> Self

pub async fn subscribe<'_>(&'_ self) -> Receiver<ServerEvent>

pub async fn close<'_>(&'_ self)

pub async fn handle_request<'_>(
    &'_ self,
    context: RequestContext
) -> Result<HandleRequestResult, ServerError>

Returns HandleRequestResult, where it tells the adapter to do certain things like setting a cookie.

pub fn handle_upgrade(&self)

pub async fn verify_request<'_, '_>(
    &'_ self,
    sid: Option<&'_ String>,
    upgrade: bool,
    transport_kind: TransportKind,
    http_method: HttpMethod
) -> Result<(), ServerError>

pub fn generate_id(&self) -> String

Generate a new ID for a client. Note: This generates IDs in a different format from the original JS engine.io implementation, which uses a library called base64id that doesn't seem to guarantee uniqueness.

pub async fn handshake<'_>(
    &'_ self,
    context: RequestContext
) -> Result<String, ServerError>

Returns the new client ID

pub async fn clients_count<'_>(&'_ self) -> usize

pub async fn get_client_or_error<'_, '_>(
    &'_ self,
    id: &'_ str
) -> Result<Arc<AsyncMutex<Socket<A>>>, ServerError>