From 259c7a08849ecba60502e2a1b7f3c287948c2b34 Mon Sep 17 00:00:00 2001 From: Alex Crichton Date: Thu, 5 Oct 2017 10:46:27 -0700 Subject: [PATCH] Make `poll_at` private again Unsure that we'll want to continue to expose this, stick to being conservative for now. --- src/reactor/interval.rs | 2 +- src/reactor/timeout.rs | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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 {