examples/async.js
@@ -3,6 +3,12 @@ var HashP = require("hashp").HashP;
var Response = exports.Response = function(status, headers, body) {
var that = this;
+ if (typeof arguments[0] === "object") {
+ headers = arguments[0].headers;
+ body = arguments[0].body;
+ status = arguments[0].status;
+ }
+
this.status = status || 200;
this.headers = HashP.merge({"Content-Type" : "text/html"}, headers);
@@ -64,7 +70,8 @@ Response.prototype.setCookie = function(key, value) {
}
if (Array.isArray(value)) {
- for (var i in value) cookie += encodeURIComponent(value[i]);
+ for (var i = 0; i < value.length; i++)
+ cookie += encodeURIComponent(value[i]);
} else {
cookie += encodeURIComponent(value);
}
@@ -138,12 +145,51 @@ Response.prototype.isEmpty = function() {
Response.redirect = function(location, status) {
status = status || 303;
+ var body = 'Go to <a href="' + location + '">' + location + '</a>';
return {
status : status,
headers : {
"Location": location,
- "Content-type": "text/plain"
+ "Content-Type": "text/plain",
+ "Content-Length": String(body)
},
- body : ['Go to <a href="' + location + '">' + location + "</a>"]
+ body : [body]
};
}
+
+var AsyncResponse = exports.AsyncResponse = function(status, headers, body) {
+ // set the buffer up first, since Response's constructor calls .write()
+ this._buffer = [];
+
+ this._callback = null;
+ this._errback = null;
+
+ Response.apply(this, arguments);
+
+ this.body = { forEach : this.forEach.bind(this) };
+}
+
+AsyncResponse.prototype = Object.create(Response.prototype);
+
+// this "write" gets overriden later by the callback provided to forEach
+AsyncResponse.prototype.write = function(chunk) {
+ this._buffer.push(chunk);
+}
+
+AsyncResponse.prototype.forEach = function(callback) {
+ this._buffer.forEach(callback);
+ this._buffer = null;
+
+ this.write = callback;
+
+ return { then : this.then.bind(this) };
+}
+
+AsyncResponse.prototype.then = function(callback, errback) {
+ this._callback = callback;
+ this._errback = errback;
+}
+
+AsyncResponse.prototype.close = function() {
+ this._callback();
+}
lib/jack/response.js
ef5fdafc989657c308def2d015cc32e234b071f8
Tom Robinson
tom@280north.com
http://github.com/gmosx/jack/commit/3ee7b56812c97770318891a0fd21287cae9ccfc2
3ee7b56812c97770318891a0fd21287cae9ccfc2
2009-10-09T04:04:51-07:00
2009-10-09T04:04:51-07:00
Added an AsyncResponse object and example.
e60efeda7e4a7dcd297fc23ea072cbd654a942f5
Tom Robinson
tom@280north.com