fix buf prev
This commit is contained in:
parent
e3a39d9a47
commit
e36fbb4bf9
|
@ -64,12 +64,15 @@ impl LiteBridge {
|
||||||
)
|
)
|
||||||
.await?;
|
.await?;
|
||||||
|
|
||||||
|
let metrics_capture = MetricsCapture::new(tx_sender.clone());
|
||||||
|
|
||||||
Ok(Self {
|
Ok(Self {
|
||||||
tx_sender,
|
tx_sender,
|
||||||
finalized_block_listenser,
|
finalized_block_listenser,
|
||||||
confirmed_block_listenser,
|
confirmed_block_listenser,
|
||||||
rpc_url,
|
rpc_url,
|
||||||
tpu_client,
|
tpu_client,
|
||||||
|
metrics_capture,
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -123,7 +126,7 @@ impl LiteBridge {
|
||||||
bail!("HTTP server stopped");
|
bail!("HTTP server stopped");
|
||||||
});
|
});
|
||||||
|
|
||||||
let metrics_capture = MetricsCapture::new(self.tx_sender.clone()).capture();
|
let metrics_capture = self.metrics_capture.capture();
|
||||||
let cleaner = Cleaner::new(
|
let cleaner = Cleaner::new(
|
||||||
self.tx_sender.clone(),
|
self.tx_sender.clone(),
|
||||||
[
|
[
|
||||||
|
|
Loading…
Reference in New Issue