diff options
Diffstat (limited to 'src/sync/self_subscriber.rs')
| -rw-r--r-- | src/sync/self_subscriber.rs | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/sync/self_subscriber.rs b/src/sync/self_subscriber.rs index 70c3dbf..ab10c49 100644 --- a/src/sync/self_subscriber.rs +++ b/src/sync/self_subscriber.rs | |||
| @@ -126,14 +126,14 @@ impl SelfSubscriber { | |||
| 126 | 126 | ||
| 127 | /// Get batch window from environment or use default | 127 | /// Get batch window from environment or use default |
| 128 | /// | 128 | /// |
| 129 | /// Reads `NGIT_SYNC_BATCH_WINDOW_MS` environment variable. | 129 | /// When `NGIT_TEST=1` is set, uses 200ms for faster test execution. |
| 130 | /// Default: 5000ms (5 seconds) | 130 | /// Default: 5000ms (5 seconds) |
| 131 | fn get_batch_window() -> Duration { | 131 | fn get_batch_window() -> Duration { |
| 132 | std::env::var("NGIT_SYNC_BATCH_WINDOW_MS") | 132 | if std::env::var("NGIT_TEST").as_deref() == Ok("1") { |
| 133 | .ok() | 133 | Duration::from_millis(200) |
| 134 | .and_then(|s| s.parse::<u64>().ok()) | 134 | } else { |
| 135 | .map(Duration::from_millis) | 135 | Duration::from_millis(5000) |
| 136 | .unwrap_or(Duration::from_millis(5000)) | 136 | } |
| 137 | } | 137 | } |
| 138 | 138 | ||
| 139 | /// Process a relay pool notification | 139 | /// Process a relay pool notification |