[feat](trx-client,trx-frontend-http): raise spectrum update rate
Co-authored-by: Codex <codex@openai.com> Signed-off-by: Stan Grams <sjg@haxx.space>
This commit is contained in:
@@ -40,7 +40,7 @@ impl RemoteEndpoint {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
const SPECTRUM_POLL_INTERVAL: Duration = Duration::from_millis(200);
|
const SPECTRUM_POLL_INTERVAL: Duration = Duration::from_millis(40);
|
||||||
|
|
||||||
pub struct RemoteClientConfig {
|
pub struct RemoteClientConfig {
|
||||||
pub addr: String,
|
pub addr: String,
|
||||||
|
|||||||
@@ -301,7 +301,7 @@ pub async fn spectrum(
|
|||||||
let context_updates = context.get_ref().clone();
|
let context_updates = context.get_ref().clone();
|
||||||
let mut last_revision: Option<u64> = None;
|
let mut last_revision: Option<u64> = None;
|
||||||
let updates =
|
let updates =
|
||||||
IntervalStream::new(time::interval(Duration::from_millis(200))).filter_map(move |_| {
|
IntervalStream::new(time::interval(Duration::from_millis(40))).filter_map(move |_| {
|
||||||
let context = context_updates.clone();
|
let context = context_updates.clone();
|
||||||
std::future::ready({
|
std::future::ready({
|
||||||
let next = context
|
let next = context
|
||||||
|
|||||||
Reference in New Issue
Block a user