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;