parent
294edc4df3
commit
2e74aa058f
|
|
@ -22,9 +22,9 @@ use crate::messages::ServerMessage;
|
||||||
/// # ClientManager
|
/// # ClientManager
|
||||||
/// This struct manages all connected users
|
/// This struct manages all connected users
|
||||||
#[derive(Debug)]
|
#[derive(Debug)]
|
||||||
pub struct ClientManager<Out>
|
pub struct ClientManager<Out: 'static>
|
||||||
where
|
where
|
||||||
Out: From<ClientMgrMessage>
|
Out: From<ClientMgrMessage> + Send
|
||||||
{
|
{
|
||||||
clients: Mutex<HashMap<Uuid, Arc<Client<ClientMgrMessage>>>>,
|
clients: Mutex<HashMap<Uuid, Arc<Client<ClientMgrMessage>>>>,
|
||||||
|
|
||||||
|
|
@ -36,7 +36,7 @@ pub struct ClientManager<Out>
|
||||||
|
|
||||||
impl<Out> ClientManager<Out>
|
impl<Out> ClientManager<Out>
|
||||||
where
|
where
|
||||||
Out: From<ClientMgrMessage>
|
Out: From<ClientMgrMessage> + Send
|
||||||
{
|
{
|
||||||
pub fn new(out_channel: Sender<Out>) -> Arc<Self> {
|
pub fn new(out_channel: Sender<Out>) -> Arc<Self> {
|
||||||
let (tx, rx) = channel(1024);
|
let (tx, rx) = channel(1024);
|
||||||
|
|
@ -192,7 +192,7 @@ impl<Out> ClientManager<Out>
|
||||||
#[async_trait]
|
#[async_trait]
|
||||||
impl<Out> IManager for ClientManager<Out>
|
impl<Out> IManager for ClientManager<Out>
|
||||||
where
|
where
|
||||||
Out: From<ClientMgrMessage>
|
Out: From<ClientMgrMessage> + Send
|
||||||
{
|
{
|
||||||
async fn run(self: &Arc<Self>) {
|
async fn run(self: &Arc<Self>) {
|
||||||
loop {
|
loop {
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue