UDP отключение клиента

import socket
 
UDP_MAX_SIZE = 65535
ENCODING = "utf-8"
 
def listen(host: str = '127.0.0.1',port: int = 9090):
    s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    s.bind((host, port))
    print(f'Listening at {host}:{port}')
 
    members = set()
    while True:
        try:
            msg, addr = s.recvfrom(UDP_MAX_SIZE)
        except ConnectionResetError as e:
            print("ERR")
            continue
 
        if addr not in members:
            members.add(addr)
 
        if not msg:
            continue
 
        client_id = addr[1]
        if msg.decode(ENCODING) == '__join':
            msg = f'Client {client_id} joined chat'
            print(msg)
        elif msg.decode(ENCODING) == '__exit':
            members.remove(addr)
            msg = f'Client {client_id} exit from chat'
            print(msg)
        else:
            msg = f'client {client_id}:{msg.decode(ENCODING)}'
 
        for member in members:
            if member == addr:
                continue
            result = s.sendto(msg.encode(ENCODING),member)
 
 
 
if __name__ == '__main__':
    listen()

import socket
import threading
import os
 
UDP_MAX_SIZE = 65535
ENCODING = "utf-8"
 
def listen(s: socket.socket):
    while True:
        msg, addr = s.recvfrom(UDP_MAX_SIZE)
        print('\r\r'+msg.decode(ENCODING)+'\n'+f'you: ',end='')
 
def connect(host: str = '127.0.0.1',port: int = 9090):
    s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    s.connect((host, port))
 
    threading.Thread(target=listen, args=(s,),daemon=True).start()
 
 
    s.sendto('__join'.encode(ENCODING),(host, port))
    print("JOIN!")
 
    while True:
        try:
            msg = input(f'you: ')
        except KeyboardInterrupt as k:
            s.sendto("__exit".encode(ENCODING), (host, port))
            s.close()
            exit()
        s.sendto(msg.encode(ENCODING), (host, port))
 
if __name__ == '__main__':
    os.system('cls')
    print('Welcome to chat')
    connect()

try:
            msg, addr = s.recvfrom(UDP_MAX_SIZE)
        except ConnectionResetError as e:
            print("ERR")
            continue

result = s.sendto(msg.encode(ENCODING),member)