Skip to content
Snippets Groups Projects
Commit a99caedf authored by Jiří Kalvoda's avatar Jiří Kalvoda
Browse files

Fixes

parent d3eb6e30
Branches
No related tags found
No related merge requests found
......@@ -93,7 +93,7 @@ class DownloadServer(communication.FuncCaller):
if len(last_data):
return last_data[-1]
else:
return wait_data(False)
return await wait_data(False)
@communication.server_exec()
async def wait_next_data(self, last_dt: datetime.datetime, preferably_compressed: bool = True):
......@@ -107,7 +107,7 @@ class DownloadServer(communication.FuncCaller):
for dt, data in last_data:
if dt > last_dt:
return dt, data
return wait_data(preferably_compressed)
return await wait_data(preferably_compressed)
async def client_connected(reader, writer):
......
......@@ -3,6 +3,6 @@ import asyncio
async def main():
s = await communication.StdInOutSocket().connect()
await communication.DownloadServer(s, is_server=True)._server_.run()
await communication.MainServer(s, is_server=True)._server_.run()
asyncio.run(main())
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment