if(typeof(Stream) == 'undefined') Stream = function () {}

Stream = function (url_cgi) {
    this.url_cgi = url_cgi;
}

Stream.VERSION = "0.01";

Stream.prototype.request = function (job, obj, async, onComplete) {
    var responseObj;
    var responseText;
    async = async ? true : false;
    onComplete = onComplete ? onComplete : function(){};
    if(!job) return;
    if(!obj) obj = {};
    new Ajax.Request(this.url_cgi, {
        encoding: 'utf-8',
        parameters: $H({
            _job    : job,
            _obj    : Object.toJSON(obj),
            _stream : 1
        }).toQueryString(),
        asynchronous: async,
        onComplete: function (res) {
            responseText = res.responseText;
            eval(res.responseText);
            responseObj = IN;
        }
    });
    this.responseText = responseText;
    return this.responseObj = responseObj;
}