diff --git a/prog/communication.py b/prog/communication.py index 6ee46eb2bd0de6ddb473ca1a084481b88413c46c..bfcb63b810d87f2f32e1ac4000a4713776771e8c 100644 --- a/prog/communication.py +++ b/prog/communication.py @@ -31,7 +31,7 @@ async def connect_stdin_stdout(): writer = asyncio.StreamWriter(w_transport, w_protocol, reader, loop) return reader, writer -class Socket(): +class Socket: async def write(): raise NotImplementedError async def read(): @@ -82,7 +82,7 @@ class UnixSocket(AsincioStreamSocket): -class MsgParser(): +class MsgParser: def __init__(self, socket): self.socket = socket self.buffer = [] @@ -116,11 +116,11 @@ def msg(head, data): assert head return int_to_str_len(len(head), 5).encode('utf-8') + int_to_str_len(len(data), 12).encode('utf-8') + head + data -class WaitingQuestion(): +class WaitingQuestion: def __init__(self, id): self.future = asyncio.get_running_loop().create_future() -class Client(): +class Client: def __init__(self, socket): self.socket = socket self.msg_parser = MsgParser(socket) @@ -151,7 +151,7 @@ class Client(): # eprint(asyncio.all_tasks()) return await q.future -class Server(): +class Server: def __init__(self, socket, callback): self.socket = socket self.msg_parser = MsgParser(socket) @@ -172,7 +172,7 @@ class Server(): def cbor_dump(x): return cbor2.dumps(x, timezone=local_timezone) -class FuncCaller(): +class FuncCaller: def __init__(self, socket=None, is_server=False): if socket == None: is_server = True diff --git a/prog/gtfs.py b/prog/gtfs.py index 595ae3059f2d46aee20316c532121667c8ec9bd0..30c512b35d8b5b3deecc80e469e7dcf65677dd54 100644 --- a/prog/gtfs.py +++ b/prog/gtfs.py @@ -47,7 +47,7 @@ class TripStop: shape_dist_traveled: float -class GtfsDay(): +class GtfsDay: def __init__(self, date, data_getter): self.date = date self.data_getter = data_getter