Skip to content

Commit 76513c9

Browse files
authored
Implement onConnect (#38)
1 parent 48a4da0 commit 76513c9

File tree

2 files changed

+14
-0
lines changed

2 files changed

+14
-0
lines changed

src/Node/HTTP.js

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -46,6 +46,16 @@ exports.listenSocket = function (server) {
4646
};
4747
};
4848

49+
exports.onConnect = function (server) {
50+
return function (cb) {
51+
return function () {
52+
server.on("connect", function (req, socket, buffer) {
53+
return cb(req)(socket)(buffer)();
54+
});
55+
};
56+
};
57+
};
58+
4959
exports.onUpgrade = function (server) {
5060
return function (cb) {
5161
return function () {

src/Node/HTTP.purs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@ module Node.HTTP
1010
, close
1111
, ListenOptions
1212
, listenSocket
13+
, onConnect
1314
, onUpgrade
1415

1516
, httpVersion
@@ -70,6 +71,9 @@ type ListenOptions =
7071
-- | Listen on a unix socket. The specified callback will be run when setup is complete.
7172
foreign import listenSocket :: Server -> String -> Effect Unit -> Effect Unit
7273

74+
-- | Listen to `connect` events on the server
75+
foreign import onConnect :: Server -> (Request -> Socket -> Buffer -> Effect Unit) -> Effect Unit
76+
7377
-- | Listen to `upgrade` events on the server
7478
foreign import onUpgrade :: Server -> (Request -> Socket -> Buffer -> Effect Unit) -> Effect Unit
7579

0 commit comments

Comments
 (0)