Use rxjs instead of rxjs/operators (#179553)

.eslintrc.js

@@ -253,6 +253,11 @@ const RESTRICTED_IMPORTS = [
     importNames: ['Route'],
     message: 'Please use @kbn/shared-ux-router instead',
   },
+  {
+    name: 'rxjs/operators',
+    message:
+      'Please, use rxjs instead: rxjs/operators is just a subset, unnecessarily duplicating the package import.',
+  },
 ];
 
 module.exports = {

examples/expressions_explorer/public/run_expressions.tsx

@@ -7,7 +7,7 @@
  */
 
 import React, { useState, useEffect } from 'react';
-import { pluck } from 'rxjs/operators';
+import { pluck } from 'rxjs';
 import {
   EuiCodeBlock,
   EuiFlexItem,

examples/partial_results_example/public/app/app.tsx

@@ -7,7 +7,7 @@
  */
 
 import React, { useContext, useEffect, useState } from 'react';
-import { pluck } from 'rxjs/operators';
+import { pluck } from 'rxjs';
 import {
   EuiBasicTable,
   EuiCallOut,

examples/partial_results_example/public/functions/count_event.ts

@@ -7,7 +7,7 @@
  */
 
 import { Observable, fromEvent } from 'rxjs';
-import { scan, startWith } from 'rxjs/operators';
+import { scan, startWith } from 'rxjs';
 import type { ExpressionFunctionDefinition } from '@kbn/expressions-plugin/common';
 
 export interface CountEventArguments {

examples/partial_results_example/public/functions/get_events.ts

@@ -7,7 +7,7 @@
  */
 
 import { Observable, fromEvent, merge } from 'rxjs';
-import { distinct, map, pluck, scan, take } from 'rxjs/operators';
+import { distinct, map, pluck, scan, take } from 'rxjs';
 import type { Datatable, ExpressionFunctionDefinition } from '@kbn/expressions-plugin/common';
 
 const EVENTS: Array<keyof WindowEventMap> = [

examples/search_examples/public/search_sessions/app.tsx

@@ -26,7 +26,7 @@ import {
   EuiText,
   EuiTitle,
 } from '@elastic/eui';
-import { catchError, map, tap } from 'rxjs/operators';
+import { catchError, map, tap } from 'rxjs';
 import { lastValueFrom, of } from 'rxjs';
 
 import { CoreStart } from '@kbn/core/public';

examples/search_examples/server/my_strategy.ts

@@ -6,7 +6,7 @@
  * Side Public License, v 1.
  */
 
-import { map } from 'rxjs/operators';
+import { map } from 'rxjs';
 import { ISearchStrategy, PluginStart } from '@kbn/data-plugin/server';
 import { IMyStrategyRequest, IMyStrategyResponse } from '../common/types';
 

packages/analytics/client/src/analytics_client/analytics_client.ts

@@ -23,7 +23,7 @@ import {
   skipWhile,
   takeUntil,
   tap,
-} from 'rxjs/operators';
+} from 'rxjs';
 import type { LogMeta } from '@kbn/logging';
 import type { IShipper } from '../shippers';
 import type {

packages/core/analytics/core-analytics-browser-internal/src/track_clicks.test.ts

@@ -6,10 +6,9 @@
  * Side Public License, v 1.
  */
 
-import { firstValueFrom, ReplaySubject } from 'rxjs';
+import { firstValueFrom, ReplaySubject, take } from 'rxjs';
 import { analyticsClientMock } from './analytics_service.test.mocks';
 import { trackClicks } from './track_clicks';
-import { take } from 'rxjs/operators';
 
 describe('trackClicks', () => {
   const addEventListenerSpy = jest.spyOn(window, 'addEventListener');

packages/core/application/core-application-browser-internal/integration_tests/application_service.test.tsx

@@ -6,8 +6,7 @@
  * Side Public License, v 1.
  */
 
-import { BehaviorSubject, type Observable } from 'rxjs';
-import { take } from 'rxjs/operators';
+import { BehaviorSubject, type Observable, take } from 'rxjs';
 import { act } from 'react-dom/test-utils';
 import { createMemoryHistory, MemoryHistory } from 'history';
 

packages/core/application/core-application-browser-internal/src/application_service.test.ts

@@ -16,7 +16,7 @@ import {
 
 import { createElement } from 'react';
 import { BehaviorSubject, firstValueFrom, Subject } from 'rxjs';
-import { bufferCount, takeUntil } from 'rxjs/operators';
+import { bufferCount, takeUntil } from 'rxjs';
 import { mount, shallow } from 'enzyme';
 import { createBrowserHistory } from 'history';
 

packages/core/application/core-application-browser-internal/src/application_service.tsx

@@ -8,7 +8,7 @@
 
 import React from 'react';
 import { BehaviorSubject, firstValueFrom, type Observable, Subject, type Subscription } from 'rxjs';
-import { map, shareReplay, takeUntil, distinctUntilChanged, filter, take } from 'rxjs/operators';
+import { map, shareReplay, takeUntil, distinctUntilChanged, filter, take } from 'rxjs';
 import { createBrowserHistory, History } from 'history';
 
 import type { PluginOpaqueId } from '@kbn/core-base-common';

packages/core/apps/core-apps-server-internal/src/bundle_routes/utils.ts

@@ -9,7 +9,7 @@
 import { createReadStream, Stats } from 'fs';
 import { createHash } from 'crypto';
 import * as Rx from 'rxjs';
-import { map, takeUntil } from 'rxjs/operators';
+import { map, takeUntil } from 'rxjs';
 
 export const generateFileHash = (fd: number): Promise<string> => {
   const hash = createHash('sha1');

packages/core/chrome/core-chrome-browser-internal/src/chrome_service.test.tsx

@@ -10,7 +10,7 @@ import { registerAnalyticsContextProviderMock } from './chrome_service.test.mock
 import { shallow, mount } from 'enzyme';
 import React from 'react';
 import * as Rx from 'rxjs';
-import { toArray } from 'rxjs/operators';
+import { toArray } from 'rxjs';
 import { injectedMetadataServiceMock } from '@kbn/core-injected-metadata-browser-mocks';
 import { docLinksServiceMock } from '@kbn/core-doc-links-browser-mocks';
 import { httpServiceMock } from '@kbn/core-http-browser-mocks';

packages/core/chrome/core-chrome-browser-internal/src/chrome_service.tsx

@@ -9,7 +9,7 @@
 import React, { useMemo } from 'react';
 import { FormattedMessage } from '@kbn/i18n-react';
 import { BehaviorSubject, combineLatest, merge, type Observable, of, ReplaySubject } from 'rxjs';
-import { mergeMap, map, takeUntil, filter } from 'rxjs/operators';
+import { mergeMap, map, takeUntil, filter } from 'rxjs';
 import { parse } from 'url';
 import { EuiLink } from '@elastic/eui';
 import useObservable from 'react-use/lib/useObservable';

packages/core/chrome/core-chrome-browser-internal/src/nav_controls/nav_controls_service.test.ts

@@ -6,7 +6,7 @@
  * Side Public License, v 1.
  */
 
-import { take } from 'rxjs/operators';
+import { take } from 'rxjs';
 import { NavControlsService } from './nav_controls_service';
 
 describe('RecentlyAccessed#start()', () => {

packages/core/chrome/core-chrome-browser-internal/src/nav_controls/nav_controls_service.ts

@@ -8,7 +8,7 @@
 
 import { sortBy } from 'lodash';
 import { BehaviorSubject, ReplaySubject } from 'rxjs';
-import { map, takeUntil } from 'rxjs/operators';
+import { map, takeUntil } from 'rxjs';
 import type {
   ChromeNavControl,
   ChromeNavControls,

packages/core/chrome/core-chrome-browser-internal/src/nav_links/nav_links_service.test.ts

@@ -7,7 +7,7 @@
  */
 
 import { BehaviorSubject, lastValueFrom } from 'rxjs';
-import { take, map, takeLast } from 'rxjs/operators';
+import { take, map, takeLast } from 'rxjs';
 import { type App, AppStatus } from '@kbn/core-application-browser';
 import { NavLinksService } from './nav_links_service';
 

packages/core/chrome/core-chrome-browser-internal/src/nav_links/nav_links_service.ts

@@ -8,7 +8,7 @@
 
 import { sortBy } from 'lodash';
 import { BehaviorSubject, ReplaySubject } from 'rxjs';
-import { map, takeUntil } from 'rxjs/operators';
+import { map, takeUntil } from 'rxjs';
 import type { IBasePath } from '@kbn/core-http-browser';
 import type { InternalHttpStart } from '@kbn/core-http-browser-internal';
 import type { PublicAppDeepLinkInfo, PublicAppInfo } from '@kbn/core-application-browser';

packages/core/chrome/core-chrome-browser-internal/src/recently_accessed/persisted_log.ts

@@ -8,7 +8,7 @@
 
 import { cloneDeep, isEqual, take } from 'lodash';
 import * as Rx from 'rxjs';
-import { map } from 'rxjs/operators';
+import { map } from 'rxjs';
 
 interface PersistedLogOptions<T = any> {
   maxLength: number | string;

packages/core/chrome/core-chrome-browser-internal/src/recently_accessed/recently_accessed_service.test.ts

@@ -7,7 +7,7 @@
  */
 
 import { Subject } from 'rxjs';
-import { takeUntil, bufferCount } from 'rxjs/operators';
+import { takeUntil, bufferCount } from 'rxjs';
 import { httpServiceMock } from '@kbn/core-http-browser-mocks';
 import { RecentlyAccessedService } from './recently_accessed_service';
 

packages/core/custom-branding/core-custom-branding-browser-internal/src/custom_branding_service.ts

@@ -7,7 +7,7 @@
  */
 
 import { Subject, BehaviorSubject } from 'rxjs';
-import { shareReplay, takeUntil, map } from 'rxjs/operators';
+import { shareReplay, takeUntil, map } from 'rxjs';
 import type {
   CustomBrandingStart,
   CustomBrandingSetup,

packages/core/elasticsearch/core-elasticsearch-server-internal/src/elasticsearch_service.test.ts

@@ -24,7 +24,7 @@ import {
 
 import type { NodesVersionCompatibility } from './version_check/ensure_es_version';
 import { BehaviorSubject, firstValueFrom, of } from 'rxjs';
-import { first, concatMap } from 'rxjs/operators';
+import { first, concatMap } from 'rxjs';
 import { REPO_ROOT } from '@kbn/repo-info';
 import { Env } from '@kbn/config';
 import { configServiceMock, getEnvOptions } from '@kbn/config-mocks';

packages/core/elasticsearch/core-elasticsearch-server-internal/src/elasticsearch_service.ts

@@ -7,7 +7,7 @@
  */
 
 import { firstValueFrom, Observable, Subject } from 'rxjs';
-import { map, takeUntil } from 'rxjs/operators';
+import { map, takeUntil } from 'rxjs';
 
 import type { Logger } from '@kbn/logging';
 import type { CoreContext, CoreService } from '@kbn/core-base-server-internal';

packages/core/elasticsearch/core-elasticsearch-server-internal/src/is_valid_connection.ts

@@ -6,7 +6,7 @@
  * Side Public License, v 1.
  */
 
-import { filter } from 'rxjs/operators';
+import { filter } from 'rxjs';
 import { errors } from '@elastic/elasticsearch';
 import { Observable, firstValueFrom } from 'rxjs';
 import { NodesVersionCompatibility } from './version_check/ensure_es_version';

packages/core/elasticsearch/core-elasticsearch-server-internal/src/retry_call_cluster.ts

@@ -7,7 +7,7 @@
  */
 
 import { defer, throwError, iif, timer } from 'rxjs';
-import { concatMap, retryWhen } from 'rxjs/operators';
+import { concatMap, retryWhen } from 'rxjs';
 
 const retryResponseStatuses = [
   503, // ServiceUnavailable

packages/core/elasticsearch/core-elasticsearch-server-internal/src/status.test.ts

@@ -6,7 +6,7 @@
  * Side Public License, v 1.
  */
 
-import { take } from 'rxjs/operators';
+import { take } from 'rxjs';
 import { Subject, of } from 'rxjs';
 
 import { ServiceStatusLevels, ServiceStatusLevel, ServiceStatus } from '@kbn/core-status-common';

packages/core/elasticsearch/core-elasticsearch-server-internal/src/status.ts

@@ -7,7 +7,7 @@
  */
 
 import { Observable, merge, of } from 'rxjs';
-import { map } from 'rxjs/operators';
+import { map } from 'rxjs';
 import { ServiceStatus, ServiceStatusLevels } from '@kbn/core-status-common';
 import { ElasticsearchStatusMeta } from './types';
 import { NodesVersionCompatibility } from './version_check/ensure_es_version';

packages/core/elasticsearch/core-elasticsearch-server-internal/src/version_check/ensure_es_version.test.ts

@@ -9,7 +9,7 @@
 import { mapNodesVersionCompatibility, pollEsNodesVersion, NodesInfo } from './ensure_es_version';
 import { loggingSystemMock } from '@kbn/core-logging-server-mocks';
 import { elasticsearchClientMock } from '@kbn/core-elasticsearch-client-server-mocks';
-import { take, delay } from 'rxjs/operators';
+import { take, delay } from 'rxjs';
 import { TestScheduler } from 'rxjs/testing';
 import { of } from 'rxjs';
 

packages/core/elasticsearch/core-elasticsearch-server-internal/src/version_check/ensure_es_version.ts

@@ -21,7 +21,7 @@ import {
   tap,
   startWith,
   shareReplay,
-} from 'rxjs/operators';
+} from 'rxjs';
 import type { Logger } from '@kbn/logging';
 import type { ElasticsearchClient } from '@kbn/core-elasticsearch-server';
 import {

packages/core/execution-context/core-execution-context-browser-internal/src/execution_context_service.ts

@@ -9,7 +9,7 @@
 import { compact, isEqual, isUndefined, omitBy } from 'lodash';
 import type { Observable } from 'rxjs';
 import { BehaviorSubject, Subscription } from 'rxjs';
-import { map } from 'rxjs/operators';
+import { map } from 'rxjs';
 import type { CoreService } from '@kbn/core-base-browser-internal';
 import type { AnalyticsServiceSetup } from '@kbn/core-analytics-browser';
 import type { KibanaExecutionContext } from '@kbn/core-execution-context-common';

packages/core/http/core-http-browser-internal/src/fetch.test.ts

@@ -10,7 +10,7 @@
 import fetchMock from 'fetch-mock/es5/client';
 import { readFileSync } from 'fs';
 import { join } from 'path';
-import { first } from 'rxjs/operators';
+import { first } from 'rxjs';
 import { executionContextServiceMock } from '@kbn/core-execution-context-browser-mocks';
 import type { HttpResponse, HttpFetchOptionsWithPath } from '@kbn/core-http-browser';
 

packages/core/http/core-http-browser-internal/src/loading_count_service.test.ts

@@ -7,7 +7,7 @@
  */
 
 import { Observable, throwError, of, Subject } from 'rxjs';
-import { toArray } from 'rxjs/operators';
+import { toArray } from 'rxjs';
 
 import { fatalErrorsServiceMock } from '@kbn/core-fatal-errors-browser-mocks';
 import { LoadingCountService } from './loading_count_service';

packages/core/http/core-http-browser-internal/src/loading_count_service.ts

@@ -7,15 +7,7 @@
  */
 
 import { BehaviorSubject, Observable, Subject } from 'rxjs';
-import {
-  distinctUntilChanged,
-  endWith,
-  map,
-  pairwise,
-  startWith,
-  takeUntil,
-  tap,
-} from 'rxjs/operators';
+import { distinctUntilChanged, endWith, map, pairwise, startWith, takeUntil, tap } from 'rxjs';
 import type { CoreService } from '@kbn/core-base-browser-internal';
 import type { FatalErrorsSetup } from '@kbn/core-fatal-errors-browser';
 

packages/core/http/core-http-router-server-internal/src/request.ts

@@ -11,7 +11,7 @@ import { v4 as uuidv4 } from 'uuid';
 import { inspect } from 'util';
 import type { Request, RouteOptions } from '@hapi/hapi';
 import { fromEvent, NEVER } from 'rxjs';
-import { shareReplay, first, filter } from 'rxjs/operators';
+import { shareReplay, first, filter } from 'rxjs';
 import { RecursiveReadonly } from '@kbn/utility-types';
 import { deepFreeze } from '@kbn/std';
 import {

packages/core/http/core-http-server-internal/src/http_server.ts

@@ -20,7 +20,7 @@ import {
 
 import type { Duration } from 'moment';
 import { firstValueFrom, Observable, Subscription } from 'rxjs';
-import { take, pairwise } from 'rxjs/operators';
+import { take, pairwise } from 'rxjs';
 import apm from 'elastic-apm-node';
 // @ts-expect-error no type definition
 import Brok from 'brok';

packages/core/http/core-http-server-internal/src/http_service.ts

@@ -7,7 +7,7 @@
  */
 
 import { Observable, Subscription, combineLatest, firstValueFrom } from 'rxjs';
-import { map } from 'rxjs/operators';
+import { map } from 'rxjs';
 import { pick } from '@kbn/std';
 
 import { Logger } from '@kbn/logging';

packages/core/integrations/core-integrations-browser-internal/src/moment/moment_service.ts

@@ -8,7 +8,7 @@
 
 import moment from 'moment-timezone';
 import { merge, Subscription } from 'rxjs';
-import { tap } from 'rxjs/operators';
+import { tap } from 'rxjs';
 
 import type { CoreService } from '@kbn/core-base-browser-internal';
 import type { IUiSettingsClient } from '@kbn/core-ui-settings-browser';

packages/core/metrics/core-metrics-server-internal/src/metrics_service.test.ts

@@ -8,7 +8,7 @@
 
 import moment from 'moment';
 
-import { take } from 'rxjs/operators';
+import { take } from 'rxjs';
 import { configServiceMock } from '@kbn/config-mocks';
 import { mockCoreContext } from '@kbn/core-base-server-mocks';
 import { loggingSystemMock } from '@kbn/core-logging-server-mocks';

packages/core/overlays/core-overlays-browser-internal/src/banners/banners_service.test.ts

@@ -7,7 +7,7 @@
  */
 
 import { InternalOverlayBannersStart, OverlayBannersService } from './banners_service';
-import { take } from 'rxjs/operators';
+import { take } from 'rxjs';
 import { i18nServiceMock } from '@kbn/core-i18n-browser-mocks';
 import { uiSettingsServiceMock } from '@kbn/core-ui-settings-browser-mocks';
 

packages/core/overlays/core-overlays-browser-internal/src/banners/banners_service.tsx

@@ -8,7 +8,7 @@
 
 import React from 'react';
 import { BehaviorSubject, type Observable } from 'rxjs';
-import { map } from 'rxjs/operators';
+import { map } from 'rxjs';
 
 import type { I18nStart } from '@kbn/core-i18n-browser';
 import type { IUiSettingsClient } from '@kbn/core-ui-settings-browser';

packages/core/overlays/core-overlays-browser-internal/src/banners/user_banner_service.tsx

@@ -8,7 +8,7 @@
 
 import React from 'react';
 import ReactDOM from 'react-dom';
-import { filter } from 'rxjs/operators';
+import { filter } from 'rxjs';
 import { Subscription } from 'rxjs';
 
 import { FormattedMessage } from '@kbn/i18n-react';

packages/core/plugins/core-plugins-server-internal/src/discovery/plugins_discovery.test.ts

@@ -15,7 +15,7 @@ import { loggingSystemMock } from '@kbn/core-logging-server-mocks';
 import type { Package } from '@kbn/repo-packages';
 
 import { firstValueFrom, from } from 'rxjs';
-import { map, toArray } from 'rxjs/operators';
+import { map, toArray } from 'rxjs';
 import { resolve } from 'path';
 import { ConfigService, Env } from '@kbn/config';
 import type { CoreContext } from '@kbn/core-base-server-internal';

packages/core/plugins/core-plugins-server-internal/src/discovery/plugins_discovery.ts

@@ -7,7 +7,7 @@
  */
 
 import { from, merge, EMPTY } from 'rxjs';
-import { catchError, filter, map, mergeMap, concatMap, shareReplay, toArray } from 'rxjs/operators';
+import { catchError, filter, map, mergeMap, concatMap, shareReplay, toArray } from 'rxjs';
 import { Logger } from '@kbn/logging';
 import { getPluginPackagesFilter } from '@kbn/repo-packages';
 import type { CoreContext } from '@kbn/core-base-server-internal';

packages/core/plugins/core-plugins-server-internal/src/discovery/scan_plugin_search_paths.test.ts

@@ -8,7 +8,7 @@
 
 import mockFs from 'mock-fs';
 import { loggingSystemMock } from '@kbn/core-logging-server-mocks';
-import { toArray } from 'rxjs/operators';
+import { toArray } from 'rxjs';
 import { resolve } from 'path';
 import { scanPluginSearchPaths } from './scan_plugin_search_paths';
 import { PluginDiscoveryError } from './plugin_discovery_error';

packages/core/plugins/core-plugins-server-internal/src/discovery/scan_plugin_search_paths.ts

@@ -9,7 +9,7 @@
 import { PathLike, readdir, stat, Stats } from 'fs';
 import { resolve } from 'path';
 import { bindNodeCallback, from, Observable } from 'rxjs';
-import { catchError, mergeMap } from 'rxjs/operators';
+import { catchError, mergeMap } from 'rxjs';
 import type { Logger } from '@kbn/logging';
 import { PluginDiscoveryError } from './plugin_discovery_error';
 

packages/core/plugins/core-plugins-server-internal/src/legacy_config.test.ts

@@ -5,7 +5,7 @@
  * in compliance with, at your election, the Elastic License 2.0 or the Server
  * Side Public License, v 1.
  */
-import { take } from 'rxjs/operators';
+import { take } from 'rxjs';
 import { getGlobalConfig, getGlobalConfig$ } from './legacy_config';
 import { duration } from 'moment';
 import { fromRoot } from '@kbn/repo-info';

packages/core/plugins/core-plugins-server-internal/src/legacy_config.ts

@@ -6,7 +6,7 @@
  * Side Public License, v 1.
  */
 
-import { map, shareReplay } from 'rxjs/operators';
+import { map, shareReplay } from 'rxjs';
 import { combineLatest, Observable } from 'rxjs';
 import { PathConfigType, config as pathConfig } from '@kbn/utils';
 import { pick, deepFreeze } from '@kbn/std';

packages/core/plugins/core-plugins-server-internal/src/plugin_context.test.ts

@@ -7,7 +7,7 @@
  */
 
 import { duration } from 'moment';
-import { first } from 'rxjs/operators';
+import { first } from 'rxjs';
 import { REPO_ROOT, fromRoot } from '@kbn/repo-info';
 import { rawConfigServiceMock, getEnvOptions, configServiceMock } from '@kbn/config-mocks';
 import type { CoreContext } from '@kbn/core-base-server-internal';

packages/core/plugins/core-plugins-server-internal/src/plugin_context.ts

@@ -6,7 +6,7 @@
  * Side Public License, v 1.
  */
 
-import { shareReplay } from 'rxjs/operators';
+import { shareReplay } from 'rxjs';
 import type { CoreContext } from '@kbn/core-base-server-internal';
 import type { PluginOpaqueId } from '@kbn/core-base-common';
 import type { NodeInfo } from '@kbn/core-node-server';

packages/core/plugins/core-plugins-server-internal/src/plugins_service.test.ts

@@ -25,7 +25,7 @@ import { PluginWrapper } from './plugin';
 import { PluginsService } from './plugins_service';
 import { PluginsSystem } from './plugins_system';
 import { config, PluginsConfigType } from './plugins_config';
-import { take } from 'rxjs/operators';
+import { take } from 'rxjs';
 import type { PluginConfigDescriptor } from '@kbn/core-plugins-server';
 import { DiscoveredPlugin, PluginType } from '@kbn/core-base-common';
 

packages/core/plugins/core-plugins-server-internal/src/plugins_service.ts

@@ -8,7 +8,7 @@
 
 import Path from 'path';
 import { firstValueFrom, Observable } from 'rxjs';
-import { filter, map, tap, toArray } from 'rxjs/operators';
+import { filter, map, tap, toArray } from 'rxjs';
 import { getFlattenedObject } from '@kbn/std';
 
 import { Logger } from '@kbn/logging';

packages/core/rendering/core-rendering-browser-internal/src/rendering_service.tsx

@@ -8,7 +8,7 @@
 
 import React from 'react';
 import ReactDOM from 'react-dom';
-import { pairwise, startWith } from 'rxjs/operators';
+import { pairwise, startWith } from 'rxjs';
 
 import type { AnalyticsServiceStart } from '@kbn/core-analytics-browser';
 import type { InternalApplicationStart } from '@kbn/core-application-browser-internal';

packages/core/rendering/core-rendering-server-internal/src/rendering_service.tsx

@@ -9,7 +9,7 @@
 import React from 'react';
 import { renderToStaticMarkup } from 'react-dom/server';
 import { firstValueFrom, of } from 'rxjs';
-import { catchError, take, timeout } from 'rxjs/operators';
+import { catchError, take, timeout } from 'rxjs';
 import { i18n } from '@kbn/i18n';
 import type { ThemeVersion } from '@kbn/ui-shared-deps-npm';
 

packages/core/root/core-root-server-internal/src/root/index.test.ts

@@ -9,7 +9,7 @@
 import { rawConfigService, configService, logger, mockServer } from './index.test.mocks';
 
 import { BehaviorSubject } from 'rxjs';
-import { filter, first } from 'rxjs/operators';
+import { filter, first } from 'rxjs';
 import { CriticalError } from '@kbn/core-base-server-internal';
 import { REPO_ROOT } from '@kbn/repo-info';
 import { Env } from '@kbn/config';

packages/core/root/core-root-server-internal/src/root/index.ts

@@ -7,14 +7,7 @@
  */
 
 import { ConnectableObservable, Subscription } from 'rxjs';
-import {
-  first,
-  publishReplay,
-  switchMap,
-  concatMap,
-  tap,
-  distinctUntilChanged,
-} from 'rxjs/operators';
+import { first, publishReplay, switchMap, concatMap, tap, distinctUntilChanged } from 'rxjs';
 import type { Logger, LoggerFactory } from '@kbn/logging';
 import type { Env, RawConfigurationProvider } from '@kbn/config';
 import { LoggingConfigType, LoggingSystem } from '@kbn/core-logging-server-internal';

packages/core/saved-objects/core-saved-objects-migration-server-internal/src/kibana_migrator.test.ts

@@ -6,7 +6,7 @@
  * Side Public License, v 1.
  */
 
-import { take } from 'rxjs/operators';
+import { take } from 'rxjs';
 import { loggingSystemMock } from '@kbn/core-logging-server-mocks';
 import { elasticsearchClientMock } from '@kbn/core-elasticsearch-client-server-mocks';
 import { elasticsearchServiceMock } from '@kbn/core-elasticsearch-server-mocks';

packages/core/saved-objects/core-saved-objects-server-internal/src/saved_objects_service.test.ts

@@ -19,7 +19,7 @@ import {
   applyTypeDefaultsMock,
 } from './saved_objects_service.test.mocks';
 import { BehaviorSubject, firstValueFrom, EMPTY } from 'rxjs';
-import { skip } from 'rxjs/operators';
+import { skip } from 'rxjs';
 import { type RawPackageInfo, Env } from '@kbn/config';
 import { ByteSizeValue } from '@kbn/config-schema';
 import { REPO_ROOT } from '@kbn/repo-info';

packages/core/saved-objects/core-saved-objects-server-internal/src/saved_objects_service.ts

@@ -7,7 +7,7 @@
  */
 
 import { Subject, Observable, firstValueFrom, of } from 'rxjs';
-import { filter, switchMap } from 'rxjs/operators';
+import { filter, switchMap } from 'rxjs';
 import type { Logger } from '@kbn/logging';
 import { stripVersionQualifier } from '@kbn/std';
 import type { ServiceStatus } from '@kbn/core-status-common';

packages/core/saved-objects/core-saved-objects-server-internal/src/status.test.ts

@@ -9,7 +9,7 @@
 import { of, Observable } from 'rxjs';
 import { type ServiceStatus, ServiceStatusLevels } from '@kbn/core-status-common';
 import { calculateStatus$ } from './status';
-import { take } from 'rxjs/operators';
+import { take } from 'rxjs';
 
 describe('calculateStatus$', () => {
   const expectUnavailableDueToEs = (status$: Observable<ServiceStatus>) =>

packages/core/saved-objects/core-saved-objects-server-internal/src/status.ts

@@ -7,7 +7,7 @@
  */
 
 import { Observable, combineLatest } from 'rxjs';
-import { startWith, map } from 'rxjs/operators';
+import { startWith, map } from 'rxjs';
 import { type ServiceStatus, ServiceStatusLevels } from '@kbn/core-status-common';
 import type { SavedObjectStatusMeta } from '@kbn/core-saved-objects-server';
 import type { KibanaMigratorStatus } from '@kbn/core-saved-objects-base-server-internal';

packages/core/status/core-status-server-internal/src/log_core_services_status.ts

@@ -8,7 +8,7 @@
 
 import { uniq } from 'lodash';
 import { merge, type Observable, Subject, type Subscription } from 'rxjs';
-import { pairwise, takeUntil, map, startWith, bufferTime, concatAll, filter } from 'rxjs/operators';
+import { pairwise, takeUntil, map, startWith, bufferTime, concatAll, filter } from 'rxjs';
 import type { Logger } from '@kbn/logging';
 import { type CoreStatus, ServiceStatusLevels } from '@kbn/core-status-common';
 import type { LoggableServiceStatus } from './types';

packages/core/status/core-status-server-internal/src/log_overall_status.ts

@@ -7,7 +7,7 @@
  */
 
 import type { Observable, Subscription } from 'rxjs';
-import { distinctUntilChanged, pairwise, takeUntil, map, startWith } from 'rxjs/operators';
+import { distinctUntilChanged, pairwise, takeUntil, map, startWith } from 'rxjs';
 import { type ServiceStatus, ServiceStatusLevels } from '@kbn/core-status-common';
 import type { Logger } from '@kbn/logging';
 

packages/core/status/core-status-server-internal/src/log_plugins_status.ts

@@ -8,7 +8,7 @@
 
 import { uniq } from 'lodash';
 import { merge, type Observable, Subject, type Subscription } from 'rxjs';
-import { pairwise, takeUntil, map, startWith, bufferTime, filter, concatAll } from 'rxjs/operators';
+import { pairwise, takeUntil, map, startWith, bufferTime, filter, concatAll } from 'rxjs';
 import { Logger } from '@kbn/logging';
 import type { PluginName } from '@kbn/core-base-common';
 import { ServiceStatusLevels } from '@kbn/core-status-common';

packages/core/status/core-status-server-internal/src/plugins_status.test.ts

@@ -10,7 +10,7 @@ import type { PluginName } from '@kbn/core-base-common';
 import { PluginsStatusService } from './plugins_status';
 import { of, Observable, BehaviorSubject, ReplaySubject, firstValueFrom } from 'rxjs';
 import { ServiceStatusLevels, CoreStatus, ServiceStatus } from '@kbn/core-status-common';
-import { first, skip } from 'rxjs/operators';
+import { first, skip } from 'rxjs';
 import { ServiceStatusLevelSnapshotSerializer } from './test_helpers';
 
 expect.addSnapshotSerializer(ServiceStatusLevelSnapshotSerializer);

packages/core/status/core-status-server-internal/src/plugins_status.ts

@@ -14,15 +14,7 @@ import {
   Subject,
   type Subscription,
 } from 'rxjs';
-import {
-  map,
-  distinctUntilChanged,
-  filter,
-  tap,
-  debounceTime,
-  takeUntil,
-  delay,
-} from 'rxjs/operators';
+import { map, distinctUntilChanged, filter, tap, debounceTime, takeUntil, delay } from 'rxjs';
 import { isDeepStrictEqual } from 'util';
 import type { PluginName } from '@kbn/core-base-common';
 import { ServiceStatusLevels, type CoreStatus, type ServiceStatus } from '@kbn/core-status-common';

packages/core/status/core-status-server-internal/src/status_service.test.ts

@@ -10,7 +10,7 @@ import { of, BehaviorSubject, firstValueFrom, Observable } from 'rxjs';
 
 import { type ServiceStatus, ServiceStatusLevels, type CoreStatus } from '@kbn/core-status-common';
 import type { ILoggingSystem } from '@kbn/core-logging-server-internal';
-import { first, take, toArray } from 'rxjs/operators';
+import { first, take, toArray } from 'rxjs';
 import { mockCoreContext } from '@kbn/core-base-server-mocks';
 import { environmentServiceMock } from '@kbn/core-environment-server-mocks';
 import { mockRouter, RouterMock } from '@kbn/core-http-router-server-mocks';

packages/core/status/core-status-server-internal/src/status_service.ts

@@ -15,7 +15,7 @@ import {
   tap,
   BehaviorSubject,
 } from 'rxjs';
-import { map, distinctUntilChanged, shareReplay, takeUntil, debounceTime } from 'rxjs/operators';
+import { map, distinctUntilChanged, shareReplay, takeUntil, debounceTime } from 'rxjs';
 import { isDeepStrictEqual } from 'util';
 
 import type { RootSchema } from '@kbn/analytics-client';

packages/core/ui-settings/core-ui-settings-browser-internal/src/ui_settings_api.test.ts

@@ -9,7 +9,7 @@
 // @ts-expect-error
 import fetchMock from 'fetch-mock/es5/client';
 import * as Rx from 'rxjs';
-import { takeUntil, toArray } from 'rxjs/operators';
+import { takeUntil, toArray } from 'rxjs';
 
 import { setup as httpSetup } from '@kbn/core-test-helpers-http-setup-browser';
 import { UiSettingsApi } from './ui_settings_api';

packages/core/ui-settings/core-ui-settings-browser-internal/src/ui_settings_client.test.ts

@@ -7,7 +7,7 @@
  */
 
 import { Subject } from 'rxjs';
-import { materialize, take, toArray } from 'rxjs/operators';
+import { materialize, take, toArray } from 'rxjs';
 
 import { UiSettingsClient } from './ui_settings_client';
 import { ValidationApiResponse } from './ui_settings_api';

packages/core/ui-settings/core-ui-settings-browser-internal/src/ui_settings_client_common.ts

@@ -8,7 +8,7 @@
 
 import { cloneDeep, defaultsDeep } from 'lodash';
 import { Observable, Subject, concat, defer, of } from 'rxjs';
-import { filter, map } from 'rxjs/operators';
+import { filter, map } from 'rxjs';
 
 import { UserProvidedValues } from '@kbn/core-ui-settings-common';
 import {

packages/core/ui-settings/core-ui-settings-browser-internal/src/ui_settings_global_client.test.ts

@@ -7,7 +7,7 @@
  */
 
 import { Subject } from 'rxjs';
-import { take, toArray } from 'rxjs/operators';
+import { take, toArray } from 'rxjs';
 
 import { UiSettingsGlobalClient } from './ui_settings_global_client';
 

packages/core/usage-data/core-usage-data-server-internal/src/core_usage_data_service.ts

@@ -7,7 +7,7 @@
  */
 
 import { Subject, Observable, firstValueFrom } from 'rxjs';
-import { takeUntil } from 'rxjs/operators';
+import { takeUntil } from 'rxjs';
 import { get } from 'lodash';
 import { hasConfigPathIntersection, ChangedDeprecatedPaths } from '@kbn/config';
 

packages/kbn-cli-dev-mode/src/base_path_proxy_server.ts

@@ -13,7 +13,7 @@ import { Server, Request } from '@hapi/hapi';
 import HapiProxy from '@hapi/h2o2';
 import { sampleSize } from 'lodash';
 import * as Rx from 'rxjs';
-import { take } from 'rxjs/operators';
+import { take } from 'rxjs';
 import { ByteSizeValue } from '@kbn/config-schema';
 import { createServer, getListenerOptions, getServerOptions } from '@kbn/server-http-tools';
 

packages/kbn-cli-dev-mode/src/cli_dev_mode.ts

@@ -20,7 +20,7 @@ import {
   switchMap,
   concatMap,
   takeUntil,
-} from 'rxjs/operators';
+} from 'rxjs';
 import { CliArgs } from '@kbn/config';
 import { CiStatsReporter } from '@kbn/ci-stats-reporter';
 import { REPO_ROOT } from '@kbn/repo-info';

packages/kbn-cli-dev-mode/src/dev_server.ts

@@ -7,17 +7,7 @@
  */
 
 import * as Rx from 'rxjs';
-import {
-  map,
-  tap,
-  take,
-  share,
-  mergeMap,
-  switchMap,
-  scan,
-  takeUntil,
-  ignoreElements,
-} from 'rxjs/operators';
+import { map, tap, take, share, mergeMap, switchMap, scan, takeUntil, ignoreElements } from 'rxjs';
 import { observeLines } from '@kbn/stdio-dev-helpers';
 
 import { usingServerProcess } from './using_server_process';

packages/kbn-cli-dev-mode/src/optimizer.test.ts

@@ -9,7 +9,7 @@
 import { PassThrough } from 'stream';
 
 import * as Rx from 'rxjs';
-import { toArray } from 'rxjs/operators';
+import { toArray } from 'rxjs';
 import { OptimizerUpdate } from '@kbn/optimizer';
 import { observeLines } from '@kbn/stdio-dev-helpers';
 import { createReplaceSerializer } from '@kbn/jest-serializers';

packages/kbn-cli-dev-mode/src/optimizer.ts

@@ -9,7 +9,7 @@
 import Chalk from 'chalk';
 import moment from 'moment';
 import { Writable } from 'stream';
-import { tap } from 'rxjs/operators';
+import { tap } from 'rxjs';
 import {
   ToolingLog,
   pickLevelFromFlags,
@@ -17,7 +17,7 @@ import {
   parseLogLevel,
 } from '@kbn/tooling-log';
 import * as Rx from 'rxjs';
-import { ignoreElements } from 'rxjs/operators';
+import { ignoreElements } from 'rxjs';
 import {
   runOptimizer,
   OptimizerConfig,

packages/kbn-config/src/config_service.test.ts

@@ -7,7 +7,7 @@
  */
 
 import { BehaviorSubject, firstValueFrom, Observable } from 'rxjs';
-import { first, map, take } from 'rxjs/operators';
+import { first, map, take } from 'rxjs';
 
 import {
   mockApplyDeprecations,

packages/kbn-config/src/config_service.ts

@@ -11,7 +11,7 @@ import { SchemaTypeError, Type, ValidationError } from '@kbn/config-schema';
 import { cloneDeep, isEqual, merge } from 'lodash';
 import { set } from '@kbn/safer-lodash-set';
 import { BehaviorSubject, combineLatest, firstValueFrom, Observable, identity } from 'rxjs';
-import { distinctUntilChanged, first, map, shareReplay, tap } from 'rxjs/operators';
+import { distinctUntilChanged, first, map, shareReplay, tap } from 'rxjs';
 import { Logger, LoggerFactory } from '@kbn/logging';
 import { getDocLinks, DocLinks } from '@kbn/doc-links';
 

packages/kbn-config/src/raw/raw_config_service.ts

@@ -8,7 +8,7 @@
 
 import { cloneDeep, isPlainObject } from 'lodash';
 import { Observable, ReplaySubject } from 'rxjs';
-import { map } from 'rxjs/operators';
+import { map } from 'rxjs';
 import typeDetect from 'type-detect';
 
 import { getConfigFromFiles } from './read_config';

packages/kbn-dev-proc-runner/src/proc.ts

@@ -13,7 +13,7 @@ import stripAnsi from 'strip-ansi';
 
 import execa from 'execa';
 import * as Rx from 'rxjs';
-import { tap, share, take, mergeMap, map, ignoreElements, filter } from 'rxjs/operators';
+import { tap, share, take, mergeMap, map, ignoreElements, filter } from 'rxjs';
 import chalk from 'chalk';
 import treeKill from 'tree-kill';
 import { ToolingLog } from '@kbn/tooling-log';

packages/kbn-dev-utils/src/extract.ts

@@ -15,7 +15,7 @@ import { promisify } from 'util';
 import Tar from 'tar';
 import Yauzl, { ZipFile, Entry } from 'yauzl';
 import * as Rx from 'rxjs';
-import { map, mergeMap, takeUntil } from 'rxjs/operators';
+import { map, mergeMap, takeUntil } from 'rxjs';
 
 const strComplete = (obs: Rx.Observable<unknown>) =>
   new Promise<void>((resolve, reject) => {

packages/kbn-ftr-common-functional-ui-services/services/remote/create_stdout_stream.ts

@@ -9,7 +9,7 @@
 import Net from 'net';
 
 import * as Rx from 'rxjs';
-import { map, takeUntil, take } from 'rxjs/operators';
+import { map, takeUntil, take } from 'rxjs';
 
 export async function createStdoutSocket() {
   const chunk$ = new Rx.Subject<Buffer>();

packages/kbn-ftr-common-functional-ui-services/services/remote/poll_for_log_entry.ts

@@ -8,7 +8,7 @@
 
 import { WebDriver, logging } from 'selenium-webdriver';
 import * as Rx from 'rxjs';
-import { mergeMap, catchError, delay, repeat } from 'rxjs/operators';
+import { mergeMap, catchError, delay, repeat } from 'rxjs';
 import { NoSuchSessionError, NoSuchWindowError } from 'selenium-webdriver/lib/error';
 
 export const FINAL_LOG_ENTRY_PREFIX = 'WEBDRIVER SESSION IS STOPPED';

packages/kbn-ftr-common-functional-ui-services/services/remote/webdriver.ts

@@ -10,7 +10,7 @@ import { resolve } from 'path';
 import Fs from 'fs';
 
 import * as Rx from 'rxjs';
-import { mergeMap, map, catchError, ignoreElements, takeWhile } from 'rxjs/operators';
+import { mergeMap, map, catchError, ignoreElements, takeWhile } from 'rxjs';
 import { Lifecycle } from '@kbn/test';
 import { ToolingLog } from '@kbn/tooling-log';
 import chromeDriver from 'chromedriver';

packages/kbn-optimizer/src/common/event_stream_helpers.test.ts

@@ -7,7 +7,7 @@
  */
 
 import * as Rx from 'rxjs';
-import { take } from 'rxjs/operators';
+import { take } from 'rxjs';
 import { allValuesFrom } from './rxjs_helpers';
 
 import { summarizeEventStream } from './event_stream_helpers';

packages/kbn-optimizer/src/log_optimizer_progress.ts

@@ -8,7 +8,7 @@
 
 import { ToolingLog } from '@kbn/tooling-log';
 import * as Rx from 'rxjs';
-import { tap } from 'rxjs/operators';
+import { tap } from 'rxjs';
 
 import { OptimizerUpdate } from './run_optimizer';
 

packages/kbn-optimizer/src/log_optimizer_state.ts

@@ -9,7 +9,7 @@
 import { inspect } from 'util';
 
 import { ToolingLog } from '@kbn/tooling-log';
-import { tap } from 'rxjs/operators';
+import { tap } from 'rxjs';
 
 import { OptimizerConfig } from './optimizer';
 import { OptimizerUpdate$ } from './run_optimizer';

packages/kbn-optimizer/src/optimizer/bundle_cache.ts

@@ -9,7 +9,7 @@
 import Fs from 'fs';
 
 import * as Rx from 'rxjs';
-import { mergeAll } from 'rxjs/operators';
+import { mergeAll } from 'rxjs';
 import { dllManifestPath } from '@kbn/ui-shared-deps-npm';
 
 import { Bundle, BundleRemotes, Hashes, parseDllManifest } from '../common';

packages/kbn-optimizer/src/optimizer/handle_optimizer_completion.ts

@@ -6,7 +6,7 @@
  * Side Public License, v 1.
  */
 
-import { tap } from 'rxjs/operators';
+import { tap } from 'rxjs';
 import { createFailError } from '@kbn/dev-cli-errors';
 
 import { pipeClosure } from '../common';

packages/kbn-optimizer/src/optimizer/observe_worker.ts

@@ -10,7 +10,7 @@ import { inspect } from 'util';
 
 import { fork, type ChildProcess } from 'child_process';
 import * as Rx from 'rxjs';
-import { map, takeUntil, first, ignoreElements } from 'rxjs/operators';
+import { map, takeUntil, first, ignoreElements } from 'rxjs';
 
 import { isWorkerMsg, WorkerConfig, WorkerMsg, Bundle, BundleRemotes } from '../common';
 

packages/kbn-optimizer/src/optimizer/run_workers.ts

@@ -7,7 +7,7 @@
  */
 
 import * as Rx from 'rxjs';
-import { mergeMap, toArray } from 'rxjs/operators';
+import { mergeMap, toArray } from 'rxjs';
 
 import { maybeMap } from '../common';
 

packages/kbn-optimizer/src/optimizer/watch_bundles_for_changes.ts

@@ -7,7 +7,7 @@
  */
 
 import * as Rx from 'rxjs';
-import { mergeMap, toArray } from 'rxjs/operators';
+import { mergeMap, toArray } from 'rxjs';
 
 import { Bundle, maybeMap } from '../common';
 

packages/kbn-optimizer/src/optimizer/watcher.ts

@@ -7,7 +7,7 @@
  */
 
 import * as Rx from 'rxjs';
-import { take, map, share } from 'rxjs/operators';
+import { take, map, share } from 'rxjs';
 import Watchpack from 'watchpack';
 
 import { debounceTimeBuffer, Bundle } from '../common';

packages/kbn-optimizer/src/report_optimizer_timings.ts

@@ -6,7 +6,7 @@
  * Side Public License, v 1.
  */
 
-import { concatMap } from 'rxjs/operators';
+import { concatMap } from 'rxjs';
 import { CiStatsReporter } from '@kbn/ci-stats-reporter';
 import { ToolingLog } from '@kbn/tooling-log';
 

packages/kbn-optimizer/src/run_optimizer.ts

@@ -7,7 +7,7 @@
  */
 
 import * as Rx from 'rxjs';
-import { mergeMap, share, observeOn } from 'rxjs/operators';
+import { mergeMap, share, observeOn } from 'rxjs';
 
 import { summarizeEventStream, Update } from './common';
 

packages/kbn-optimizer/src/worker/run_compilers.ts

@@ -10,7 +10,7 @@ import 'source-map-support/register';
 
 import webpack, { Stats } from 'webpack';
 import * as Rx from 'rxjs';
-import { mergeMap, map, mapTo, takeUntil } from 'rxjs/operators';
+import { mergeMap, map, mapTo, takeUntil } from 'rxjs';
 import { isFailureStats, failedStatsToErrorMessage } from '@kbn/optimizer-webpack-helpers';
 
 import {

packages/kbn-optimizer/src/worker/run_worker.ts

@@ -9,7 +9,7 @@
 import { inspect } from 'util';
 
 import * as Rx from 'rxjs';
-import { take, mergeMap } from 'rxjs/operators';
+import { take, mergeMap } from 'rxjs';
 
 import {
   parseBundles,

packages/kbn-reporting/export_types/pdf/printable_pdf.ts

@@ -8,7 +8,7 @@
 
 import apm from 'elastic-apm-node';
 import { Observable, fromEventPattern, lastValueFrom, of, throwError } from 'rxjs';
-import { catchError, map, mergeMap, takeUntil, tap } from 'rxjs/operators';
+import { catchError, map, mergeMap, takeUntil, tap } from 'rxjs';
 import { Writable } from 'stream';
 
 import type { LicenseType } from '@kbn/licensing-plugin/server';