LumeWeb
/
ethers-rs
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: close example subscriptions after 2 emitted items (#1892) 

cargo +nightly fmt

Co-authored-by: Andrea Simeoni <>
This commit is contained in:
Andrea Simeoni 2022-11-26 17:42:41 +01:00 committed by GitHub
parent 585280f29c
commit b0ef1343dd
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
examples/subscribe_events_by_type.rs
View File

@ -27,14 +27,13 @@ async fn main() -> Result<(), Box<dyn Error>> {
// refine the event filter // refine the event filter
let event = Contract::event_of_type::<AnswerUpdatedFilter>(&client) let event = Contract::event_of_type::<AnswerUpdatedFilter>(&client)
.from_block(16022082) .from_block(16022082)
.to_block(16022282)
.address(ValueOrArray::Array(vec![ .address(ValueOrArray::Array(vec![
PRICE_FEED_1.parse()?, PRICE_FEED_1.parse()?,
PRICE_FEED_2.parse()?, PRICE_FEED_2.parse()?,
PRICE_FEED_3.parse()?, PRICE_FEED_3.parse()?,
])); ]));
let mut stream = event.subscribe_with_meta().await?; let mut stream = event.subscribe_with_meta().await?.take(2);
// Note that `log` has type AnswerUpdatedFilter // Note that `log` has type AnswerUpdatedFilter
while let Some(Ok((log, meta))) = stream.next().await { while let Some(Ok((log, meta))) = stream.next().await {

2
examples/subscribe_logs.rs
View File

@ -17,7 +17,7 @@ async fn main() -> Result<()> {
let erc20_transfer_filter = let erc20_transfer_filter =
Filter::new().from_block(last_block - 25).event("Transfer(address,address,uint256)"); Filter::new().from_block(last_block - 25).event("Transfer(address,address,uint256)");
let mut stream = client.subscribe_logs(&erc20_transfer_filter).await?; let mut stream = client.subscribe_logs(&erc20_transfer_filter).await?.take(2);
while let Some(log) = stream.next().await { while let Some(log) = stream.next().await {
println!( println!(