octo
/
Zebra
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

use FuturesOrdered in fallback_verification test (#4867)

This commit is contained in:
Conrado Gouvea 2022-08-02 13:04:35 -03:00 committed by GitHub
parent 0f01c9f442
commit c7f681d410
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tower-batch/tests/ed25519.rs
View File

@ -4,7 +4,7 @@ use std::time::Duration;
use color_eyre::{eyre::eyre, Report}; use color_eyre::{eyre::eyre, Report};
use ed25519_zebra::*; use ed25519_zebra::*;
use futures::stream::{FuturesUnordered, StreamExt}; use futures::stream::{FuturesOrdered, StreamExt};
use rand::thread_rng; use rand::thread_rng;
use tower::{Service, ServiceExt}; use tower::{Service, ServiceExt};
use tower_batch::Batch; use tower_batch::Batch;
@ -24,7 +24,7 @@ async fn sign_and_verify<V>(
where where
V: Service<Ed25519Item, Response = ()>, V: Service<Ed25519Item, Response = ()>,
{ {
let results = FuturesUnordered::new(); let mut results = FuturesOrdered::new();
for i in 0..n { for i in 0..n {
let span = tracing::trace_span!("sig", i); let span = tracing::trace_span!("sig", i);
let sk = SigningKey::new(thread_rng()); let sk = SigningKey::new(thread_rng());