async-logic.ts

/**
 * Handling of time, network requests, and asynchronous
 * logic more generally cannot be done by reducers.
 */

export const profileEpic = action => action.pipe(
  ofType(SEARCH_PROFILE),
  
  // Only allow one search every 300ms
  debounceTime(300),
  
  // Cancel duplicate searches using `switchMap`
  switchMap(term => getProfileByTerm(term).pipe(
    map(({ body }) => new SearchProfileSuccessAction(body)),
    
    // Async error handling. For epics this should probably be
    // done to handle service errors. If errors propagate to
    // the epic, the epic will be canceled and stop listening
    catchError(() => of(new SearchProfileFailureAction()),
  )
);