Skip to content

Commit

Permalink
m2node.run() now returns the handler. This is so that later the socke…
Browse files Browse the repository at this point in the history
…ts can be closed gracefully with:

handler.pullSocket.close();
handler.pubSocket.close();
  • Loading branch information
Paul Bergeron committed Jun 28, 2011
1 parent f9ccf71 commit 566d1ac
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 1 deletion.
3 changes: 2 additions & 1 deletion lib/m2node.js
Expand Up @@ -6,7 +6,7 @@
exports.run = function(server, options) { exports.run = function(server, options) {
var handler; var handler;
handler = new Handler(options); handler = new Handler(options);
return handler.on('request', function(request) { handler.on('request', function(request) {
var fakeSocket; var fakeSocket;
fakeSocket = new FakeSocket(); fakeSocket = new FakeSocket();
fakeSocket.on('write', function() { fakeSocket.on('write', function() {
Expand All @@ -15,5 +15,6 @@
server.emit('connection', fakeSocket); server.emit('connection', fakeSocket);
return fakeSocket.emitData(request.toFullHttpRequest()); return fakeSocket.emitData(request.toFullHttpRequest());
}); });
return handler;
}; };
}).call(this); }).call(this);
2 changes: 2 additions & 0 deletions package.json
Expand Up @@ -5,6 +5,8 @@
"keywords" : ["http", "mongrel2"], "keywords" : ["http", "mongrel2"],
"homepage" : "https://github.com/dan-manges/m2node", "homepage" : "https://github.com/dan-manges/m2node",
"author" : "Dan Manges <dan.manges@gmail.com> (http://www.dan-manges.com)", "author" : "Dan Manges <dan.manges@gmail.com> (http://www.dan-manges.com)",
"contributors" :
[ "Paul Bergeron <paul.d.bergeron@gmail.com>" ],
"main" : "./lib/m2node.js", "main" : "./lib/m2node.js",
"repository" : { "type": "git", "url" : "https://github.com/dan-manges/m2node.git" }, "repository" : { "type": "git", "url" : "https://github.com/dan-manges/m2node.git" },
"engines" : { "node": "~0.4.8" }, "engines" : { "node": "~0.4.8" },
Expand Down
1 change: 1 addition & 0 deletions src/m2node.coffee
Expand Up @@ -11,4 +11,5 @@ exports.run = (server, options) ->
handler.sendResponse(request, fakeSocket.writeBuffer) handler.sendResponse(request, fakeSocket.writeBuffer)
server.emit 'connection', fakeSocket server.emit 'connection', fakeSocket
fakeSocket.emitData(request.toFullHttpRequest()) fakeSocket.emitData(request.toFullHttpRequest())
handler


0 comments on commit 566d1ac

Please sign in to comment.