Removing get prefix from poll_info
This commit is contained in:
parent
4cfcaf8521
commit
027f122aea
@ -84,7 +84,7 @@ impl<F, T> PollManager<F, T> where T: Timer {
|
|||||||
}
|
}
|
||||||
|
|
||||||
/// Returns number of block when last poll happend.
|
/// Returns number of block when last poll happend.
|
||||||
pub fn get_poll_info(&mut self, id: &PollId) -> Option<&PollInfo<F>> {
|
pub fn poll_info(&mut self, id: &PollId) -> Option<&PollInfo<F>> {
|
||||||
self.polls.prune();
|
self.polls.prune();
|
||||||
self.polls.get(id)
|
self.polls.get(id)
|
||||||
}
|
}
|
||||||
@ -124,21 +124,21 @@ mod tests {
|
|||||||
|
|
||||||
*time.borrow_mut() = 10;
|
*time.borrow_mut() = 10;
|
||||||
indexer.update_poll(&0, 21);
|
indexer.update_poll(&0, 21);
|
||||||
assert_eq!(indexer.get_poll_info(&0).unwrap().filter, false);
|
assert_eq!(indexer.poll_info(&0).unwrap().filter, false);
|
||||||
assert_eq!(indexer.get_poll_info(&0).unwrap().block_number, 21);
|
assert_eq!(indexer.poll_info(&0).unwrap().block_number, 21);
|
||||||
|
|
||||||
*time.borrow_mut() = 30;
|
*time.borrow_mut() = 30;
|
||||||
indexer.update_poll(&1, 23);
|
indexer.update_poll(&1, 23);
|
||||||
assert_eq!(indexer.get_poll_info(&1).unwrap().filter, true);
|
assert_eq!(indexer.poll_info(&1).unwrap().filter, true);
|
||||||
assert_eq!(indexer.get_poll_info(&1).unwrap().block_number, 23);
|
assert_eq!(indexer.poll_info(&1).unwrap().block_number, 23);
|
||||||
|
|
||||||
*time.borrow_mut() = 75;
|
*time.borrow_mut() = 75;
|
||||||
indexer.update_poll(&0, 30);
|
indexer.update_poll(&0, 30);
|
||||||
assert!(indexer.get_poll_info(&0).is_none());
|
assert!(indexer.poll_info(&0).is_none());
|
||||||
assert_eq!(indexer.get_poll_info(&1).unwrap().filter, true);
|
assert_eq!(indexer.poll_info(&1).unwrap().filter, true);
|
||||||
assert_eq!(indexer.get_poll_info(&1).unwrap().block_number, 23);
|
assert_eq!(indexer.poll_info(&1).unwrap().block_number, 23);
|
||||||
|
|
||||||
indexer.remove_poll(&1);
|
indexer.remove_poll(&1);
|
||||||
assert!(indexer.get_poll_info(&1).is_none());
|
assert!(indexer.poll_info(&1).is_none());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -307,7 +307,7 @@ impl EthFilter for EthFilterClient {
|
|||||||
let client = take_weak!(self.client);
|
let client = take_weak!(self.client);
|
||||||
from_params::<(Index,)>(params)
|
from_params::<(Index,)>(params)
|
||||||
.and_then(|(index,)| {
|
.and_then(|(index,)| {
|
||||||
let info = self.polls.lock().unwrap().get_poll_info(&index.value()).cloned();
|
let info = self.polls.lock().unwrap().poll_info(&index.value()).cloned();
|
||||||
match info {
|
match info {
|
||||||
None => Ok(Value::Array(vec![] as Vec<Value>)),
|
None => Ok(Value::Array(vec![] as Vec<Value>)),
|
||||||
Some(info) => match info.filter {
|
Some(info) => match info.filter {
|
||||||
|
Loading…
Reference in New Issue
Block a user