diff --git a/node_modules/@rocket.chat/sdk/lib/api/api.ts b/node_modules/@rocket.chat/sdk/lib/api/api.ts
index 17c2c2b..cb094e8 100644
--- a/node_modules/@rocket.chat/sdk/lib/api/api.ts
+++ b/node_modules/@rocket.chat/sdk/lib/api/api.ts
@@ -117,24 +117,31 @@ class Client implements IClient {
       JSON.stringify(data)
   }
 
+  getSignal (options?: any): AbortSignal {
+    return options && options.signal;
+  }
+
   get (url: string, data: any, options?: any): Promise<any> {
     return fetch(`${this.host}/api/v1/${encodeURI(url)}?${this.getParams(data)}`, {
       method: 'GET',
-      headers: this.getHeaders(options)
+      headers: this.getHeaders(options),
+      signal: this.getSignal(options)
     }).then(this.handle)
   }
   post (url: string, data: any, options?: any): Promise<any> {
     return fetch(`${this.host}/api/v1/${encodeURI(url)}`, {
       method: 'POST',
       body: this.getBody(data),
-      headers: this.getHeaders(options)
+      headers: this.getHeaders(options),
+      signal: this.getSignal(options)
     }).then(this.handle)
   }
   put (url: string, data: any, options?: any): Promise<any> {
     return fetch(`${this.host}/api/v1/${encodeURI(url)}`, {
       method: 'PUT',
       body: this.getBody(data),
-      headers: this.getHeaders(options)
+      headers: this.getHeaders(options),
+      signal: this.getSignal(options)
     }).then(this.handle)
   }
 
@@ -142,7 +149,8 @@ class Client implements IClient {
     return fetch(`${this.host}/api/v1/${encodeURI(url)}`, {
       method: 'DELETE',
       body: this.getBody(data),
-      headers: this.getHeaders(options)
+      headers: this.getHeaders(options),
+      signal: this.getSignal(options)
     }).then(this.handle)
   }
   private async handle (r: any) {
@@ -176,11 +184,13 @@ export default class Api extends EventEmitter {
     authToken: string,
     result: ILoginResultAPI
   } | null = null
+  controller: AbortController
 
   constructor ({ client, host, logger = Logger }: any) {
     super()
     this.client = client || new Client({ host } as any)
     this.logger = Logger
+    this.controller = new AbortController();
   }
 
   get username () {
@@ -212,6 +222,10 @@ export default class Api extends EventEmitter {
       if (auth && !this.loggedIn()) {
         throw new Error('')
       }
+
+      const { signal } = this.controller;
+      options = { ...options, signal };
+
       let result
       switch (method) {
         case 'GET': result = await this.client.get(endpoint, data, options); break
@@ -242,6 +256,8 @@ export default class Api extends EventEmitter {
 	/** Do a DELETE request to an API endpoint. */
   del: IAPIRequest = (endpoint, data, auth, ignore, options = {}) => this.request('DELETE', endpoint, data, auth, ignore, options)
 
+  abort = (): void => this.controller.abort()
+
 	/** Check result data for success, allowing override to ignore some errors */
   success (result: any, ignore?: RegExp) {
     return (
diff --git a/node_modules/@rocket.chat/sdk/lib/drivers/ddp.ts b/node_modules/@rocket.chat/sdk/lib/drivers/ddp.ts
index 247ce8b..2687abc 100644
--- a/node_modules/@rocket.chat/sdk/lib/drivers/ddp.ts
+++ b/node_modules/@rocket.chat/sdk/lib/drivers/ddp.ts
@@ -538,7 +538,8 @@ export class DDPDriver extends EventEmitter implements ISocket, IDriver {
       'notification',
       'rooms-changed',
       'subscriptions-changed',
-      'uiInteraction'
+      'uiInteraction',
+      'userData'
     ].map(event => this.subscribe(topic, `${this.userId}/${event}`, false)))
   }