client.py

import socket

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((socket.gethostname(), 8001))

while True:
    text = input() + '\n'
    s.send(text.encode())

server.py

import socket
import distributed
from collections import Counter

e = distributed.Executor("localhost:8786")

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.bind((socket.gethostname(), 8001))
s.listen(1) 
(clientsocket, address) = s.accept()
f = clientsocket.makefile()

count = e.submit(Counter)
while True:
    out = f.readline()
    if out:
        count = e.submit(lambda x, y: x + Counter(y), count, out.split())
        print(count.result())