Describe how RxJS handles a complicated data stream

complicated-stream.js

keyPressSources.pipe(
	// Input handlers to take input value for searching
	switchMap(value => {
		return from(fetchCakesByName(value)).pipe(
			// Only make an API request for searching after 0.5s since user stopped pressing a key
			debounce(0.5),
			// Retry 3 times if an API request fails
			retry(3),
			// Cancel the search when press Esc or clear input
			takeUntil(value => value === 'Esc' || value === ''),
			// Handling errors by showing an error alerts
			catchError(error => alert('Error in getting cakes'))
		)
	}),
)