React Suspend behavior for RXJS Observables. Handles the suspension of emitted values of the source observable by prepending values for loading and error states.

rxjs-suspend.ts

function suspend<T>(): OperatorFunction<T, SuspendedValue<T>> {
  return (source: Observable<T>) =>
    source.pipe(
      map((next) => ({
        value: next,
        isLoading: false,
        error: null
      })),
      catchError((error) => of({ error, isLoading: false, value: null })),
      startWith({ isLoading: true, value: null, error: null })
    );
}

// Usage Example
const data$ = this.http.get<Config>('url').pipe(suspend());