``` source.retryWhen { it.flatMap { e -> ...
# rx
v
Copy code
source.retryWhen {
  it.flatMap { e ->
    rxFlowable {
      println("pause...")
      delay(1000)
      send(e)
   }
}