Tag: rx java

如何使用Observable实现轮询？

我有一个参数化的rest调用应该每隔五秒用不同的参数执行： Observable restCall = api.method1(param1); 我需要创建一个Observable ，它将使用param1的不同值每5秒轮询一次restCall。 如果api调用失败，我需要收到错误并在5秒内进行下一次调用。 应仅在restCall完成时（成功/错误）测量调用之间的间隔。 我目前正在使用RxJava，但.NET示例也会很好。