| 55 | |
| 56 | # tag::TCP_MOJIFINDER_MAIN[] |
| 57 | async def supervisor(index: InvertedIndex, host: str, port: int) -> None: |
| 58 | server = await asyncio.start_server( # <1> |
| 59 | functools.partial(finder, index), # <2> |
| 60 | host, port) # <3> |
| 61 | |
| 62 | socket_list = cast(tuple[TransportSocket, ...], server.sockets) # <4> |
| 63 | addr = socket_list[0].getsockname() |
| 64 | print(f'Serving on {addr}. Hit CTRL-C to stop.') # <5> |
| 65 | await server.serve_forever() # <6> |
| 66 | |
| 67 | def main(host: str = '127.0.0.1', port_arg: str = '2323'): |
| 68 | port = int(port_arg) |