conn = connect(1234)
write(conn, "Hello world!\n")
println(conn, "hello again")
function foo()
for i in 5:8
produce(i)
end
t = Task(foo)
consume(t)