Fix InternalEventReader::poll timeout computation (#511)
This commit is contained in:
parent
467a884bae
commit
30ce6364a9
@ -65,7 +65,7 @@ impl InternalEventReader {
|
|||||||
let poll_timeout = PollTimeout::new(timeout);
|
let poll_timeout = PollTimeout::new(timeout);
|
||||||
|
|
||||||
loop {
|
loop {
|
||||||
let maybe_event = match event_source.try_read(timeout) {
|
let maybe_event = match event_source.try_read(poll_timeout.leftover()) {
|
||||||
Ok(None) => None,
|
Ok(None) => None,
|
||||||
Ok(Some(event)) => {
|
Ok(Some(event)) => {
|
||||||
if filter.eval(&event) {
|
if filter.eval(&event) {
|
||||||
|
Loading…
Reference in New Issue
Block a user