Pipeable/lettable operators are functions that are passed an observable and return an observable, so there’s no source observable for the retry operator to be connected to.

The source observable will be passed into the function returned by the retry operator when the operator is applied to the source observable using pipe.

For example:

const composed = source.pipe(retry(3, 1000));

Here, source will be passed to the function returned by the call to retry and that function will return the observable assigned to composed.

RxJS core team member; front-end developer; mentor; speaker; open-source contributor

Get the Medium app

A button that says 'Download on the App Store', and if clicked it will lead you to the iOS App store
A button that says 'Get it on, Google Play', and if clicked it will lead you to the Google Play store