make it compile
This commit is contained in:
parent
258e889f69
commit
0d07e20d7c
@ -899,7 +899,7 @@ impl Web3Rpc {
|
|||||||
) -> anyhow::Result<()> {
|
) -> anyhow::Result<()> {
|
||||||
trace!("watching new heads on {}", self);
|
trace!("watching new heads on {}", self);
|
||||||
|
|
||||||
let mut unlocked_provider = self.provider.read().await;
|
let mut unlocked_provider = self.provider.read().await.clone();
|
||||||
|
|
||||||
let mut logged = false;
|
let mut logged = false;
|
||||||
while unlocked_provider.is_none() {
|
while unlocked_provider.is_none() {
|
||||||
@ -907,11 +907,11 @@ impl Web3Rpc {
|
|||||||
sleep(Duration::from_millis(100)).await;
|
sleep(Duration::from_millis(100)).await;
|
||||||
|
|
||||||
if !logged {
|
if !logged {
|
||||||
debug!("no provider for subscribe_new_heads on {}", self.rpc);
|
debug!("no provider for subscribe_new_heads on {}", self);
|
||||||
logged = true;
|
logged = true;
|
||||||
}
|
}
|
||||||
|
|
||||||
unlocked_provider = self.rpc.provider.read().await.clone();
|
unlocked_provider = self.provider.read().await.clone();
|
||||||
}
|
}
|
||||||
|
|
||||||
match unlocked_provider.as_deref() {
|
match unlocked_provider.as_deref() {
|
||||||
@ -1093,7 +1093,7 @@ impl Web3Rpc {
|
|||||||
) -> anyhow::Result<()> {
|
) -> anyhow::Result<()> {
|
||||||
// TODO: give this a separate client. don't use new_head_client for everything. especially a firehose this big
|
// TODO: give this a separate client. don't use new_head_client for everything. especially a firehose this big
|
||||||
// TODO: timeout
|
// TODO: timeout
|
||||||
let mut provider = self.provider.read().await;
|
let mut provider = self.provider.read().await.clone();
|
||||||
|
|
||||||
let mut logged = false;
|
let mut logged = false;
|
||||||
while provider.is_none() {
|
while provider.is_none() {
|
||||||
@ -1103,16 +1103,14 @@ impl Web3Rpc {
|
|||||||
if !logged {
|
if !logged {
|
||||||
debug!(
|
debug!(
|
||||||
"no provider for subscribe_pending_transactions handle on {}",
|
"no provider for subscribe_pending_transactions handle on {}",
|
||||||
self.rpc
|
self
|
||||||
);
|
);
|
||||||
logged = true;
|
logged = true;
|
||||||
}
|
}
|
||||||
|
|
||||||
provider = self.rpc.provider.read().await.clone();
|
provider = self.provider.read().await.clone();
|
||||||
}
|
}
|
||||||
|
|
||||||
let provider = provider.expect("provider was checked already");
|
|
||||||
|
|
||||||
trace!("watching pending transactions on {}", self);
|
trace!("watching pending transactions on {}", self);
|
||||||
// TODO: does this keep the lock open for too long?
|
// TODO: does this keep the lock open for too long?
|
||||||
match provider.as_deref() {
|
match provider.as_deref() {
|
||||||
|
Loading…
Reference in New Issue
Block a user