IllegalStateException in retryWhen with ReadStreamAdapter

Question

当对我的一个外部服务的外部 http 请求失败时，我正在使用 retryWhen。 问题是我正在使用

  RxHelper.toObservable(httpClient.request(method, url))

为了得到我的可观察响应，并且因为 vertx 在内部使用 ReadStreamAdapter 我不能使用 retryWhen 因为它会抱怨

 java java.lang.IllegalStateException: Request already complete

这里是一个代码示例：

  RxHelper.toObservable(httpClient.request(method, url))
  .retryWhen(new ServiceExceptionRetry())       
  .subscribe(f -> replySuccess(eventMsg, event, f), t -> handleError(t, eventMsg, event));

知道如何实现吗？

Answer 1

您可以使用defer 从method 和client 每次像这样创建一个Observable：

 Observable.defer(() -> RxHelper.toObservable(httpClient.request(method, url)))
  .retryWhen(new ServiceExceptionRetry())       
  .subscribe(f -> replySuccess(eventMsg, event, f), t -> handleError(t, eventMsg, event));