chore: add param in listen function to enable or disable interval

tcavenezuela · Jul 1, 2024 · 94b996e · 94b996e
1 parent ad1b1fd
commit 94b996e
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git a/.changeset/stale-balloons-stare.md b/.changeset/stale-balloons-stare.md
@@ -0,0 +1,5 @@
+---
+'@fsuipc.js/api': patch
+---
+
+add param in listen function to enable or disable interval
diff --git a/packages/api/src/index.ts b/packages/api/src/index.ts
@@ -1,5 +1,5 @@
 import { FSUIPC, Simulator, Type, FSUIPCError } from 'fsuipc.js';
-import { timer, from, Observable, throwError } from 'rxjs';
+import { timer, from, Observable, throwError, of } from 'rxjs';
 import { switchMap, catchError, map } from 'rxjs/operators';
 
 // Utils
@@ -41,6 +41,7 @@ export class FsuipcApi {
   }
 
   public listen(
+    useInterval: boolean,
     interval: number,
     offsetList: string[],
     terminateOnError = true
@@ -51,7 +52,9 @@ export class FsuipcApi {
 
     this.watchOffsets(offsetList);
 
-    return timer(interval, interval).pipe(
+    const source$ = useInterval ? timer(interval, interval) : of(null);
+
+    return source$.pipe(
       switchMap(() =>
         from(this.fsuipc.process()).pipe(
           map((result: object) => {