soulseek-rs-lib 13.0.0

Library for Soulseek protocol implementation in Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

use std::sync::{Mutex, MutexGuard, RwLock, RwLockReadGuard, RwLockWriteGuard};

use crate::error::{Result, SoulseekRs};

pub trait RwLockExt<T> {
    fn read_safe(&self) -> Result<RwLockReadGuard<'_, T>>;
    fn write_safe(&self) -> Result<RwLockWriteGuard<'_, T>>;
}

impl<T> RwLockExt<T> for RwLock<T> {
    fn read_safe(&self) -> Result<RwLockReadGuard<'_, T>> {
        self.read().map_err(|_| SoulseekRs::LockPoisoned)
    }

    fn write_safe(&self) -> Result<RwLockWriteGuard<'_, T>> {
        self.write().map_err(|_| SoulseekRs::LockPoisoned)
    }
}

pub trait MutexExt<T> {
    fn lock_safe(&self) -> Result<MutexGuard<'_, T>>;
}

impl<T> MutexExt<T> for Mutex<T> {
    fn lock_safe(&self) -> Result<MutexGuard<'_, T>> {
        self.lock().map_err(|_| SoulseekRs::LockPoisoned)
    }
}