From 96ab74bd163096c50de86bb93a9193335fff98fd Mon Sep 17 00:00:00 2001 From: Matthieu Riegler Date: Tue, 2 Jan 2024 00:59:18 +0100 Subject: [PATCH] chore: reuse existing error Let remove duplicates in the code base ! --- packages/rxjs/src/internal/Observable.ts | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/packages/rxjs/src/internal/Observable.ts b/packages/rxjs/src/internal/Observable.ts index b7cb6dddde..6a5ccfab49 100644 --- a/packages/rxjs/src/internal/Observable.ts +++ b/packages/rxjs/src/internal/Observable.ts @@ -15,6 +15,7 @@ import type { ErrorNotification, NextNotification, } from './types.js'; +import { createInvalidObservableTypeError } from './util/throwUnobservableError.js'; /** * An error thrown when one or more errors have occurred during the @@ -1259,11 +1260,7 @@ export function getObservableInputType(input: unknown): ObservableInputType { if (isReadableStreamLike(input)) { return ObservableInputType.ReadableStreamLike; } - throw new TypeError( - `You provided ${ - input !== null && typeof input === 'object' ? 'an invalid object' : `'${input}'` - } where a stream was expected. You can provide an Observable, Promise, ReadableStream, Array, AsyncIterable, or Iterable.` - ); + throw createInvalidObservableTypeError(input); } /**