uliweb gevent long polling test

views.py

#coding=utf-8
from uliweb import expose, functions

import gevent
from gevent.queue import Queue, Empty

import json as json_

data_source = Queue()

def producer():
    while True:
        data_source.put_nowait('Hello World')
        gevent.sleep(1)
        #print "producer output"

g_producer = None

@expose('/')
def index():
    global g_producer
    if not g_producer:
        g_producer = gevent.spawn(producer)
    response.content_type = 'application/json'
    while True:
        try:
            datum = data_source.get(timeout=5)
            #print "consumer got input"
            yield json_.dumps(datum) + '\n'
        except Empty:
            pass