Struct CoreLocalAdapter

pub struct CoreLocalAdapter<E> { /* private fields */ }

The default adapter. Store the state in memory.

Implementations

impl<E: SocketEmitter> CoreLocalAdapter<E>

pub fn new(emitter: E) -> Self

Create a new local adapter with the given sockets interface.

pub fn close(&self)

Clears all the rooms and sockets.

pub fn add_all(&self, sid: Sid, rooms: impl RoomParam)

Adds the socket to all the rooms.

pub fn del(&self, sid: Sid, rooms: impl RoomParam)

Removes the socket from the rooms.

pub fn del_all(&self, sid: Sid)

Removes the socket from all the rooms.

pub fn broadcast( &self, packet: Packet, opts: BroadcastOptions, ) -> Result<(), Vec<SocketError>>

Broadcasts the packet to the sockets that match the BroadcastOptions.

pub fn broadcast_with_ack( &self, packet: Packet, opts: BroadcastOptions, timeout: Option<Duration>, ) -> (E::AckStream, u32)

Broadcasts the packet to the sockets that match the BroadcastOptions and return a stream of ack responses. Also returns the number of local expected aknowledgements to know when to stop waiting.

pub fn sockets(&self, opts: BroadcastOptions) -> Vec<Sid>

Returns the sockets ids that match the BroadcastOptions.

pub fn fetch_sockets(&self, opts: BroadcastOptions) -> Vec<RemoteSocketData>

Returns the sockets ids that match the BroadcastOptions.

pub fn socket_rooms(&self, sid: Sid) -> HashSet<Room>

Returns the rooms of the socket.

pub fn add_sockets(&self, opts: BroadcastOptions, rooms: impl RoomParam)

Adds the sockets that match the BroadcastOptions to the rooms.

pub fn del_sockets(&self, opts: BroadcastOptions, rooms: impl RoomParam)

Removes the sockets that match the BroadcastOptions from the rooms.

pub fn disconnect_socket( &self, opts: BroadcastOptions, ) -> Result<(), Vec<SocketError>>

Disconnects the sockets that match the BroadcastOptions.

pub fn rooms(&self, opts: BroadcastOptions) -> HashSet<Room>

Returns all the matching rooms

pub fn path(&self) -> &Str

Get the namespace path.

pub fn parser(&self) -> impl Parse + '_

Get the parser of the namespace.

pub fn server_id(&self) -> Uid

Get the unique server identifier