diff --git a/src/reactor/interval.rs b/src/reactor/interval.rs index bf766b9a7..647ea45bf 100644 --- a/src/reactor/interval.rs +++ b/src/reactor/interval.rs @@ -68,7 +68,7 @@ impl Interval { /// otherwise functions as this future's `poll` function. This will block a /// task if one isn't already blocked or update a previous one if already /// blocked. - pub fn poll_at(&mut self, now: Instant) -> Poll, io::Error> { + fn poll_at(&mut self, now: Instant) -> Poll, io::Error> { if self.next <= now { self.next = next_interval(self.next, now, self.interval); self.token.reset_timeout(self.next, &self.handle); diff --git a/src/reactor/timeout.rs b/src/reactor/timeout.rs index 92bf0a2cc..e1a8f3f7a 100644 --- a/src/reactor/timeout.rs +++ b/src/reactor/timeout.rs @@ -77,7 +77,7 @@ impl Timeout { /// otherwise functions as this future's `poll` function. This will block a /// task if one isn't already blocked or update a previous one if already /// blocked. - pub fn poll_at(&mut self, now: Instant) -> Poll<(), io::Error> { + fn poll_at(&mut self, now: Instant) -> Poll<(), io::Error> { if self.when <= now { Ok(Async::Ready(())) } else {