When the passed timespan elapses before the source emits any given value, it will unsubscribe from the source, and switch the subscription to another observable.

Deprecation Notes

Replaced with timeout. Instead of timeoutWith(100, a$, scheduler), use timeout with the configuration object: timeout({ each: 100, with: () => a$, scheduler }). Instead of timeoutWith(someDate, a$, scheduler), use timeout with the configuration object: timeout({ first: someDate, with: () => a$, scheduler }). Will be removed in v8.

timeoutWith<T, R>(due: number | Date, withObservable: ObservableInput<R>, scheduler?: SchedulerLike): OperatorFunction<T, T | R>

Parameters

Returns

OperatorFunction<T, T | R>: A function that returns an Observable that mirrors behaviour of the source Observable, unless timeout happens when it starts emitting values from the ObservableInput passed as a second parameter.

Description

Used to switch to a different observable if your source is being slow.

Useful in cases where:

• You want to switch to a different source that may be faster.
• You want to notify a user that the data stream is slow.
• You want to emit a custom error rather than the TimeoutError emitted by the default usage of timeout.

If the first parameter is passed as Date and the time of the Date arrives before the first value arrives from the source, it will unsubscribe from the source and switch the subscription to another observable.

Use Date object to switch to a different observable if the first value doesn't arrive by a specific time.

Can be used to set a timeout only for the first value, however it's recommended to use the timeout operator with the first configuration to get the same effect.

Examples

Fallback to a faster observable

import { interval, timeoutWith } from 'rxjs';

const slow$ = interval(1000);
const faster$ = interval(500);

slow$
  .pipe(timeoutWith(900, faster$))
  .subscribe(console.log);

Emit your own custom timeout error

import { interval, timeoutWith, throwError } from 'rxjs';

class CustomTimeoutError extends Error {
  constructor() {
    super('It was too slow');
    this.name = 'CustomTimeoutError';
  }
}

const slow$ = interval(1000);

slow$
  .pipe(timeoutWith(900, throwError(() => new CustomTimeoutError())))
  .subscribe({
    error: err => console.error(err.message)
  });

See Also

• timeout