Rx framework – IObservable<T>.Retry

Yan Cui

I help clients go faster for less using serverless technologies.

This article is brought to you by

Don’t reinvent the patterns. Catalyst gives you consistent APIs for messaging, data, and workflow with key microservice patterns like circuit-breakers and retries for free.

Try the Catalyst beta

As Wes Dyer put very elegantly:

Retry is to Repeat as Catch is to Concat

Ok ok, I know that’s not an exact quote, but I’m sure this is what he intended to say in the first instance :-P

Anyhow, the IObservable<T>.Retry method has all the same features of its Repeat sister method, in that:

1. You can invoke it as extension method:

var zs = xs.Retry(3);

or as static method:

var zs = Observable.Retry(xs, 3);

2. If you don’t give it a count, it’ll retry indefinitely

3. xs.Retry(1) subscribes to xs only once, and xs.Retry(0) will not subscribe to xs at all.

Only this time, the repetition of the observable collection only happens on exception. So, if you take the illustration from the previous post and swap the colours around and you will arrive at a pretty accurate illustration of how Retry works:

image

Whenever you’re ready, here are 3 ways I can help you:

  1. Production-Ready Serverless: Join 20+ AWS Heroes & Community Builders and 1000+ other students in levelling up your serverless game. This is your one-stop shop for quickly levelling up your serverless skills.
  2. I help clients launch product ideas, improve their development processes and upskill their teams. If you’d like to work together, then let’s get in touch.
  3. Join my community on Discord, ask questions, and join the discussion on all things AWS and Serverless.

Leave a Comment

Your email address will not be published. Required fields are marked *