如何在RxDart中重试流？

Question

我是一个新来的飞镖和颤栗，我正面临着一个障碍。

我正在用flutter开发一个应用程序，它使用网络调用、令牌调用等，我使用的是Dio和RxDart。问题是，在默认情况下，我需要重试每个api调用5次，直到从服务器获得适当的响应(例如，当我调用令牌服务器时，第一次调用响应202次，第二次或第三次调用响应200次)。我怎么再打电话？

这是我的获取方法：

  Future _get(String url, {Map<String, dynamic> headers}) async {
    var response = await dio.get(url, options:
    new Options(headers: headers));
    return response.data;
  }

以及一种返回未来可观测的方法：

 Observable get2(String url, {Map<String, dynamic> headers}) {
return Observable.retry(_sourceStream(url, headers: headers) , 5);

}

 Stream Function() _sourceStream(String url, {Map<String, dynamic> headers}) {
return  () => Observable.fromFuture(_get(url, headers: headers));

}

我知道RxDart中有一个RxDart工厂方法，但是我无法在我的方法中正确地使用它。有人能帮忙吗？

Answer 1

用Observable.retry

Observable.retry(() => Observable.fromFuture(_get(url, headers: headers)), 5)

用RetryWhenStream

    int retries = 0;
    RetryWhenStream(
      () => Observable.fromFuture(_get(url, headers: headers))),
      (e, s) {
        retries+=1;
        // if there is more than 5 retries, throw an error
        if (retries <= 5) return Observable.just('Lets retry again');
        return Observable.error(e);
      },
    );

当有人开始听这些流时，它将开始重试5次(如果有错误)。