fix: change to theta since we already use for private stuff

ngxs · Mar 22, 2024 · a1a872d · a1a872d
1 parent 2d575ac
commit a1a872d
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/packages/store/src/internal/unhandled-rxjs-error-callback.ts b/packages/store/src/internal/unhandled-rxjs-error-callback.ts
@@ -1,10 +1,10 @@
 import { config } from 'rxjs';
 
-const __unhandledRxjsErrorCallbacks = new WeakMap<any, VoidFunction>();
+const ɵɵunhandledRxjsErrorCallbacks = new WeakMap<any, VoidFunction>();
 
 const existingHandler = config.onUnhandledError;
 config.onUnhandledError = function (error: any) {
-  const unhandledErrorCallback = __unhandledRxjsErrorCallbacks.get(error);
+  const unhandledErrorCallback = ɵɵunhandledRxjsErrorCallbacks.get(error);
   if (unhandledErrorCallback) {
     unhandledErrorCallback();
   } else if (existingHandler) {
@@ -15,7 +15,7 @@ config.onUnhandledError = function (error: any) {
 };
 
 export function executeUnhandledCallback(error: any) {
-  const unhandledErrorCallback = __unhandledRxjsErrorCallbacks.get(error);
+  const unhandledErrorCallback = ɵɵunhandledRxjsErrorCallbacks.get(error);
   if (unhandledErrorCallback) {
     unhandledErrorCallback();
     return true;
@@ -29,7 +29,7 @@ export function assignUnhandledCallback(error: any, callback: VoidFunction) {
   // The error can also be a string if thrown in the following manner: `throwError('My Error')`.
   if (error !== null && typeof error === 'object') {
     let hasBeenCalled = false;
-    __unhandledRxjsErrorCallbacks.set(error, () => {
+    ɵɵunhandledRxjsErrorCallbacks.set(error, () => {
       if (!hasBeenCalled) {
         hasBeenCalled = true;
         callback();

diff --git a/packages/store/tests/issues/issue-759-dispatching-empty.spec.ts b/packages/store/tests/issues/issue-759-dispatching-empty.spec.ts
@@ -163,7 +163,7 @@ describe('Dispatching an empty array with errors (https://github.com/ngxs/store/
     expect(subscription.closed).toEqual(true);
   });
 
-  it('dispatch([ new ActionEmptyArray(), new ActionDispatchError() ])', async () => {
+  it('dispatch([ new ActionEmptyArray(), new ActionDispatchError() ])', () => {
     subscription = store
       .dispatch([new ActionEmptyArray(), new ActionDispatchError()])
       .pipe(finalize(() => events.push('finalize')))