Python-сообщество

     async def serverInit(self, sigServ):
        self.signal = sigServ
        self.run = True
        self.server = await asyncio.start_server(self.readFromServer, self.host, self.port)
        await self.server.serve_forever()
    async def readFromServer(self, reader, writer):
        self.writers.append(writer)
        data = await reader.read(1024)
        if(self.run == True):
            self.signal.emit(f'Received: {data.decode()!r}')
        writer.close()
    def stop(self):
        self.run = False
        for w in self.writers:
            w.close()
        time.sleep(1)
        self.server.close()