diff --git a/src/async.js b/src/async.js
index c2bafc2..1f56349 100644
--- a/src/async.js
+++ b/src/async.js
@@ -25,7 +25,7 @@ class AsyncSRT extends EventEmitter {
   static TimeoutMs = DEFAULT_PROMISE_TIMEOUT_MS;
 
   constructor() {
-
+    super()
     DEBUG && debug('Creating task-runner worker instance');
 
     this._worker = new Worker(path.resolve(__dirname, './async-worker.js'));
diff --git a/types/srt-api-async.d.ts b/types/srt-api-async.d.ts
index 40b56f9..7f000f9 100644
--- a/types/srt-api-async.d.ts
+++ b/types/srt-api-async.d.ts
@@ -1,11 +1,11 @@
-
+import { EventEmitter } from "events";
 import { SRTLoggingLevel, SRTResult, SRTSockOpt, SRTSockStatus } from "../src/srt-api-enums";
 
 import { SRTReadReturn, SRTFileDescriptor, SRTEpollEvent, SRTSockOptValue, SRTStats } from "./srt-api"
 
 export type AsyncSRTCallback<T> = (result: T) => void;
 
-export class AsyncSRT {
+export class AsyncSRT extends EventEmitter {
 
   static TimeoutMs: number;