Browse Source
Tweak waiting time for new values on channels in tests
Provide separate values for tests in debug and release mode (longer timeouts are
needed by some tests, if they use full-length payout curve)
debug-collab-settlement
Mariusz Klochowicz
3 years ago
No known key found for this signature in database
GPG Key ID: 470C865699C8D4D
1 changed files with
8 additions and
2 deletions
-
daemon/tests/harness/flow.rs
|
|
@ -4,6 +4,9 @@ use daemon::tokio_ext::FutureExt; |
|
|
|
use std::time::Duration; |
|
|
|
use tokio::sync::watch; |
|
|
|
|
|
|
|
/// Waiting time for the time on the watch channel before returning error
|
|
|
|
const NEXT_WAIT_TIME: Duration = Duration::from_secs(if cfg!(debug_assertions) { 120 } else { 30 }); |
|
|
|
|
|
|
|
/// Returns the first `Cfd` from both channels
|
|
|
|
///
|
|
|
|
/// Ensures that there is only one `Cfd` present in both channels.
|
|
|
@ -55,9 +58,12 @@ where |
|
|
|
T: Clone, |
|
|
|
{ |
|
|
|
rx.changed() |
|
|
|
.timeout(Duration::from_secs(10)) |
|
|
|
.timeout(NEXT_WAIT_TIME) |
|
|
|
.await |
|
|
|
.context("No change in channel within 10 seconds")??; |
|
|
|
.context(format!( |
|
|
|
"No change in channel within {} seconds", |
|
|
|
NEXT_WAIT_TIME.as_secs() |
|
|
|
))??; |
|
|
|
|
|
|
|
Ok(rx.borrow().clone()) |
|
|
|
} |
|
|
|