Fix Huddle CI lint failures

Co-authored-by: Kenny Lopez <klopez4212@gmail.com>
Co-authored-by: Princess Donut <b238ea756dee4d98afa5883fc7f1de61eeabe65bf700e3a5a5a80db5e42e2c2b@buzz.block.builderlab.xyz>
Signed-off-by: Kenny Lopez <klopez4212@gmail.com>
This commit is contained in:
Kenny Lopez
2026-08-17 19:12:55 +01:00
co-authored by Princess Donut
parent ddaaef418b
commit 2368ed605a
2 changed files with 12 additions and 12 deletions
+11 -10
View File
@@ -78,6 +78,16 @@ pub struct RosterDelta {
pub left: Option<RosterPeer>,
}
/// Successful local admission: peer ID, routing index, audio/control receivers,
/// and the authoritative roster revision assigned to the join.
pub type PeerAdmission = (
Uuid,
u8,
mpsc::Receiver<Bytes>,
mpsc::Receiver<PeerCtrl>,
u64,
);
/// Reason a peer was refused entry to a room.
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub enum AdmissionError {
@@ -229,16 +239,7 @@ impl Room {
&self,
pubkey: String,
requested_version: u8,
) -> Result<
(
Uuid,
u8,
mpsc::Receiver<Bytes>,
mpsc::Receiver<PeerCtrl>,
u64,
),
AdmissionError,
> {
) -> Result<PeerAdmission, AdmissionError> {
let mut g = self.guard.lock().map_err(
|_| AdmissionError::Ended, /* poisoned ≈ shutting down */
)?;
+1 -2
View File
@@ -75,8 +75,7 @@ class _BufferedEvent {
_BufferedEvent(this.subId, this.event);
}
/// Manages websocket subscriptions, event batching, reconnection with replay,
/// and pending event tracking. Equivalent to the desktop's RelayClientSession.
/// Manages websocket subscriptions, batching, reconnection, and pending events.
typedef RelaySocketFactory =
RelaySocket Function({
required String wsUrl,