Function timeoutHandler

service/src/modifyHandler.ts:27–51

(
  opts: TimeoutOptions<TRequest, TError>,
  handler: (req: TRequest) => ObservableInput<TNext> // type of arg2 of .listen
)

 * times out with the specified duration and errorFactory.
 */
export function timeoutHandler<TRequest, TNext, TError = Error>(
  opts: TimeoutOptions<TRequest, TError>,
  handler: (req: TRequest) => ObservableInput<TNext> // type of arg2 of .listen
): (req: TRequest) => ObservableInput<TNext> {
  const timeout = opts.duration;
  if (!timeout) return handler;

  const duration = timeout;

  const errFactory = opts.errorFactory
    ? opts.errorFactory
    : (_req: TRequest) => {
        return new Error(`Rxfx process timed out in ${duration} ms`);
      };

  return (req: TRequest) => {
    const handlingResult = handler(req);
    const timerOut = after(
      duration,
      throwError(() => errFactory(req))
    ) as typeof handlingResult;

    return race(handlingResult, timerOut);
  };
}

/** Decorates a handler such that when it is running, the given `progressCallback` is invoked
 * at the specified interval, passing the interval time in msec as an option.