didWriteToREPL.jl

didWriteToREPL.jl

function didWriteToREPL(f)
  origout = STDOUT
  rout, wout = redirect_stdout()

  didWrite = false

  t = @async begin
    r = ""
    didWriteLinebreak = false
    while isopen(rout)
      r = readavailable(rout)
      didRead = length(r) > 0
      if !didWrite && didRead
        print(origout, "\r         \r")
      end
      didWrite |= didRead
      write(origout, r)
      if didRead
        didWriteLinebreak = r[end] == 0x0a
      end
    end
    didWriteLinebreak
  end

  res = nothing
  didWrite = false
  didWriteLinebreakOut = false
  try
    res = f()
  catch e
    res = e
  finally
    redirect_stdout(origout)
    close(wout)
    try
      didWriteLinebreakOut = wait(t)
    catch e
      didWriteLinebreakOut = false
      @show e
    end
  end
  return res, didWrite, didWriteLinebreakOut
end

julia> didWriteToREPL() do
         for i = 1:10
           println(i)
           sleep(0.2)
         end
       end
1
2
3
4
5
6
e = InterruptException()
(InterruptException(), true, false)