test_streaming.lua

#!/usr/local/bin/lua

require "wsapi.cgi"
require "socket"

local function sleep(n)
  socket.select(nil, nil, n)
end

local function run(wsapi_env)
  local headers = {["Content-type"] = "text/plain"}

  local function show_counter()
    for i = 1,3 do
      local message = string.format("Counter is at %d\n", i)
      coroutine.yield(message)
      sleep(0.5)
    end
  end
  return 200, headers, coroutine.wrap(show_counter)
end

wsapi.cgi.run(run)