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

Fix typo

parent 7aa506d5
No related branches found
No related tags found
No related merge requests found
......@@ -55,7 +55,7 @@ class SSHRunSocket(Socket):
# eprint("READ END", r)
return r
class AsincioStreamSocket(Socket):
class AsyncioStreamSocket(Socket):
async def connect(self, reader, writer):
self.reader = reader
self.writer = writer
......@@ -70,12 +70,12 @@ class AsincioStreamSocket(Socket):
# eprint("STDIN READ END", r)
return r
class StdInOutSocket(AsincioStreamSocket):
class StdInOutSocket(AsyncioStreamSocket):
async def connect(self):
self.reader, self.writer = await connect_stdin_stdout()
return self
class UnixSocket(AsincioStreamSocket):
class UnixSocket(AsyncioStreamSocket):
async def connect(self, path):
self.reader, self.writer = await asyncio.open_unix_connection(path)
return self
......
......@@ -112,7 +112,7 @@ class DownloadServer(communication.FuncCaller):
async def client_connected(reader, writer):
await catch_all(DownloadServer(await communication.AsincioStreamSocket().connect(reader, writer), is_server=True)._server_.run())
await catch_all(DownloadServer(await communication.AsyncioStreamSocket().connect(reader, writer), is_server=True)._server_.run())
async def main():
global caio_ctx
......
......@@ -167,7 +167,7 @@ async def main():
loaded_timestamps = []
async def client_connected(reader, writer):
s = PreprocessServer(await communication.AsincioStreamSocket().connect(reader, writer), is_server=True)
s = PreprocessServer(await communication.AsyncioStreamSocket().connect(reader, writer), is_server=True)
s.ths = ths
s.loaded_timestamps = loaded_timestamps
await catch_all(s._server_.run())
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment