|
@@ -59,10 +59,10 @@ class Server:
|
|
|
|
|
|
async def run_server(self):
|
|
|
logging.info("===== Started server...")
|
|
|
- if 0: # loop.create_connection method (search about Protocol?)
|
|
|
- reader, _ = await loop.create_connection(host=self.host, port=self.input_port)
|
|
|
+ if 0: # loop.create_connection method
|
|
|
+ reader, _ = await loop.create_connection(asyncio.Transport, host=self.host, port=self.input_port)
|
|
|
self._reader = reader
|
|
|
- _, writer = await loop.create_connection(host=self.host, port=self.output_port)
|
|
|
+ _, writer = await loop.create_connection(asyncio.Transport, host=self.host, port=self.output_port)
|
|
|
self._writer = writer
|
|
|
elif 1: # asyncio.open_connection method
|
|
|
reader, _ = await asyncio.open_connection(self.host, self.input_port)
|
|
@@ -148,6 +148,9 @@ class Server:
|
|
|
|
|
|
|
|
|
if __name__ == '__main__':
|
|
|
+ print("https://stackoverflow.com/questions/48023911/aiohttp-error-connect-call-failed-for-multiple-async-requests"
|
|
|
+ "-to-localhost")
|
|
|
+ exit()
|
|
|
log_formatter = logging.Formatter(
|
|
|
"%(asctime)s [%(module)-15s %(levelname)-8s] %(message)s",
|
|
|
style='%'
|