diff --git a/node_zeromq/zmq-tests.ts b/node_zeromq/zmq-tests.ts
index a982c60d41..ef7e0f02b4 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 8df3ee8c68..23e75cc1ee 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' {
@@ -158,6 +160,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;