or you could use loopback

perform("network")
  .on(
Event::class.java,
ErrorEvent::class.java
)
  .transform{  Network() }
  .loopBack{ if( error && event.count < 3) ErrorEvent else SuccessEvent }

perform("error show")
  .on(ErrorEvent::class.java)
  .reduce{ error }

perform("success show")
  .on(SuccessEvent::class.java)
  .reduce{ Success }

Can you use that for asynchronous sources as well, like, let's say I want to retry 3 times but only when there's network connection? Kind of what you can do with

retryWhen

We get to work with the Rx Operators in the transformer which is powerful enough to handle all the cases. Orbit with

.transform {}

,

.reduce{}

,

.loopback{}

keeps the MVI pattern clear and super easy to read but does not replace the RxStream