async chat

aclient.py

import queue
import asyncio
import threading
from tkinter import *
from tkinter.ttk import *



async def receiver(r):
    while True:
        Qin.put_nowait(await r.read(100))


async def sender(w):
    while True:
        w.write(await Qout.get())
        await w.drain()
        Qout.task_done()


async def main():
    r,w = await asyncio.open_connection('localhost', 4321)
    a = asyncio.create_task(sender(w))
    b = asyncio.create_task(receiver(r))
    await asyncio.gather(a,b)
    
    

def populate_text():
    while True:
        text.insert(END, Qin.get().decode())
        
        
def submit():
    msg = entry.get().encode()
    entry.delete(0,END)
    loop.call_soon_threadsafe(lambda: Qout.put_nowait(msg))
    # Qout.put_nowait(msg)
    
loop = asyncio.get_event_loop()

Qin = queue.Queue()
Qout = asyncio.Queue(loop=loop)
n = threading.Thread(target=loop.run_until_complete, args=(main(),), daemon=True)
p = threading.Thread(target=populate_text, daemon=True)

tk = Tk()
text = Text(tk)
text.pack()
entry = Entry(tk)
entry.pack(fill=X)
entry.bind('<Return>', lambda cb: submit())
tk.after(1, n.start)
tk.after(1, p.start)
tk.mainloop()