async.jl

function stream_user_input(c::Channel)
    while true
        line = readline()
        if line == ""
            put!(c, ">>bye")
            break
        else
            put!(c, line)
        end
    end
end

function process_inputs(c::Channel)
    while true
        line = take!(c)
        line == ">>bye" && break
        @info "Received line: $line"
    end
    @info "thank you"
end

function main()
    c = Channel(5)
    @async process_inputs(c)
    stream_user_input(c)
end

main()