如何通過改造提出 10 個(gè)并行請求。請幫我解決這個(gè)問題。我嘗試使用 zip 運(yùn)算符，但我只能在 Java 中使用 Function9。public Single<List<Response<MyResponse>>> getRequest(...) { return Single.zip(getNyRequest(sessionId, RequestParams.getParams( "")), getNyRequest(sessionId, RequestParams.getParams( "")), getNyRequest(sessionId, RequestParams.getParams("")), getNyRequest(sessionId, RequestParams.getParams("")), getNyRequest(sessionId, RequestParams.getParams("")), getNyRequest(sessionId, RequestParams.getParams("")), getNyRequest(sessionId, RequestParams.getParams("")), getNyRequest(sessionId, RequestParams.getParams("")), getNyRequest(sessionId, RequestParams.getParams("")), getNyRequest(sessionId, RequestParams.getParams("")), (result1, result2, result3, result4, result5, result6, result7, result8, result9, result10) -> { });}
1 回答
蕭十郎
TA貢獻(xiàn)1815條經(jīng)驗(yàn) 獲得超13個(gè)贊
您可以使用可迭代的：
List<Single<String>> singles = Arrays.asList(Single.just("1"), Single.just("2"), Single.just("3"));
Single<List<String>> zip = Single.zip(singles, objects -> Stream.of(objects).map(o -> (String) o).collect(Collectors.toList()));
在你的情況下：
List<Single<Response<MyResponse>>> singles = Arrays.asList(getNyRequest(sessionId, RequestParams
.getParams("")), getNyRequest(sessionId, RequestParams.getParams("")), ....);
Single<List<Response<MyResponse>>> zip = Single.zip(singles,
objects -> Stream.of(objects).map(o -> (Response<MyResponse>) o).collect(Collectors.toList()));
編輯： 每 10 分鐘重復(fù)一次：
getRequest(...).repeatWhen(c -> c.delay(10, TimeUnit.MINUTES))
.subscribe();
添加回答
舉報(bào)
0/150
提交
取消