From b353038db391d6973946ea5def8b6054ff487e09 Mon Sep 17 00:00:00 2001 From: Panu Horsmalahti Date: Mon, 8 Dec 2014 12:02:25 +0200 Subject: [PATCH] Add .on() function to zeromq and a test for it. --- node_zeromq/zmq-tests.ts | 4 ++++ node_zeromq/zmq.d.ts | 9 +++++++++ 2 files changed, 13 insertions(+) diff --git a/node_zeromq/zmq-tests.ts b/node_zeromq/zmq-tests.ts index bb97fd2cad..ed0e8a5219 100644 --- a/node_zeromq/zmq-tests.ts +++ b/node_zeromq/zmq-tests.ts @@ -1,4 +1,5 @@ /// +/// import zmq = require('zmq'); @@ -18,6 +19,9 @@ function test3() { var sock = zmq.socket('push'); sock.bindSync('tcp://127.0.0.1:3000'); sock.send(['hello', 'world']); + sock.on('message', function (buffer: Buffer) { + // + }); } function test4() { diff --git a/node_zeromq/zmq.d.ts b/node_zeromq/zmq.d.ts index 7e81dd2171..8911fa62fb 100644 --- a/node_zeromq/zmq.d.ts +++ b/node_zeromq/zmq.d.ts @@ -3,6 +3,8 @@ // Definitions by: Dave McKeown // Definitions: https://github.com/borisyankov/DefinitelyTyped +/// + interface EventEmitter {} declare module 'zmq' { @@ -150,6 +152,13 @@ declare module 'zmq' { */ close(): Socket; + /** + * Socket event + * @param eventName {string} + * @param callback {Function} + */ + on(eventName: string, callback: (buffer: Buffer) => void): void; + // Socket Options _fd: any; _ioevents: any;