tikv
/
client-rust
mirror of https://github.com/tikv/client-rust.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

use try_for_each_concurrent in reduce() 

Signed-off-by: ekexium <ekexium@gmail.com>
This commit is contained in:
ekexium 2020-09-28 10:45:33 +08:00
parent 6fca06a7cb
commit 344f7cce75
2 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/raw/requests.rs
View File

@ -330,7 +330,9 @@ impl KvRequest for kvrpcpb::RawDeleteRangeRequest {
fn reduce(
results: BoxStream<'static, Result<Self::Result>>,
) -> BoxFuture<'static, Result<Self::Result>> {
results.try_for_each(|_| future::ready(Ok(()))).boxed()
results
.try_for_each_concurrent(None, |_| future::ready(Ok(())))
.boxed()
}
}

12
src/transaction/requests.rs
View File

@ -346,7 +346,9 @@ impl KvRequest for kvrpcpb::PrewriteRequest {
fn reduce(
results: BoxStream<'static, Result<Self::Result>>,
) -> BoxFuture<'static, Result<Self::Result>> {
results.try_for_each(|_| future::ready(Ok(()))).boxed()
results
.try_for_each_concurrent(None, |_| future::ready(Ok(())))
.boxed()
}
}
@ -405,7 +407,9 @@ impl KvRequest for kvrpcpb::CommitRequest {
fn reduce(
results: BoxStream<'static, Result<Self::Result>>,
) -> BoxFuture<'static, Result<Self::Result>> {
results.try_for_each(|_| future::ready(Ok(()))).boxed()
results
.try_for_each_concurrent(None, |_| future::ready(Ok(())))
.boxed()
}
}
@ -450,7 +454,9 @@ impl KvRequest for kvrpcpb::BatchRollbackRequest {
fn reduce(
results: BoxStream<'static, Result<Self::Result>>,
) -> BoxFuture<'static, Result<Self::Result>> {
results.try_for_each(|_| future::ready(Ok(()))).boxed()
results
.try_for_each_concurrent(None, |_| future::ready(Ok(())))
.boxed()
}
}