diff --git a/model.py b/model.py index 2997019..34e6b3d 100644 --- a/model.py +++ b/model.py @@ -101,10 +101,11 @@ class Model(object): self.model["clients"][clientname] = newclient return clientname - def subscribe(self, clientid, socket): + async def subscribe(self, clientid, socket): if not clientid in self.sockets: self.sockets[clientid] = [] self.sockets[clientid].append(socket) + await self.send_state(clientid) def unsubscribe(self, socket): for client in self.sockets: