return rxjs to devextreme-angular

Author: GoodDayForSurf

packages/devextreme-angular/package.json

@@ -62,6 +62,7 @@
     "karma-webpack": "5.0.1",
     "ng-packagr": "19.2.2",
     "puppeteer": "23.6.1",
+    "rxjs": "7.8.2",
     "reflect-metadata": "0.1.13",
     "stream-browserify": "3.0.0",
     "style-loader": "3.3.4",

packages/devextreme-angular/tests/src/http/ajax-bootstrap-interceptors.spec.ts

@@ -1,5 +1,4 @@
 import { TestBed } from '@angular/core/testing';
-import { Observable } from '@angular/core/rxjs-interop';
 import { HttpClientTestingModule, HttpTestingController } from '@angular/common/http/testing';
 import {
   provideHttpClient,
@@ -12,6 +11,7 @@ import { bootstrapApplication } from '@angular/platform-browser';
 import { DxHttpModule } from 'devextreme-angular/http';
 import DataSource from 'devextreme/data/data_source';
 import ODataStore from 'devextreme/data/odata/store';
+import { throwError } from 'rxjs';
 
 const TEST_URL = '';
 const interceptors: Record<string, () => void> = {};
@@ -20,13 +20,10 @@ interceptors.interceptorFn = () => {};
 
 const testInterceptorFn: HttpInterceptorFn = () => {
   interceptors.interceptorFn();
-  
-  return new Observable(observer => {
-    observer.error({
-      status: 403,
-      statusText: 'Request intercepted. Access Denied',
-    });
-  });
+  return throwError(() => ({
+    status: 403,
+    statusText: 'Request intercepted. Access Denied',
+  }));
 };
 
 @Component({

packages/devextreme-angular/tests/src/http/ajax.spec.ts

@@ -11,6 +11,7 @@ import DataSource from 'devextreme/data/data_source';
 import ODataStore from 'devextreme/data/odata/store';
 import ajax from 'devextreme/core/utils/ajax';
 import { DxFileUploaderComponent, DxFileUploaderModule } from 'devextreme-angular';
+import { Observable } from 'rxjs';
 import createSpy = jasmine.createSpy;
 import RemoteFileSystemProvider from 'devextreme/file_management/remote_provider';
 import FileSystemItem from 'devextreme/file_management/file_system_item';
@@ -23,7 +24,7 @@ jasmine.DEFAULT_TIMEOUT_INTERVAL = 1000;
 
 @Injectable()
 export class TestInterceptor implements HttpInterceptor {
-  intercept(req: HttpRequest<any>, next: HttpHandler) {
+  intercept(req: HttpRequest<any>, next: HttpHandler): Observable<HttpEvent<any>> {
     interceptors.interceptorFn();
     return next.handle(req);
   }