Rename methods

Signed-off-by: Zahari Dichev <zaharidichev@gmail.com>

Author: zaharidichev

linkerd/proxy/core/src/resolve.rs

@@ -82,16 +82,16 @@ where
 }
 
 pub trait ResolutionStreamExt<E, T>: TryStream<Ok = Update<E>, Error = T> {
-    fn next_update(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<Update<E>, T>> {
+    fn poll_next_update(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<Update<E>, T>> {
         self.try_poll_next(cx)
             .map(|result| result.expect("resolution stream never ends"))
     }
 
-    fn next_update_pin(&mut self, cx: &mut Context<'_>) -> Poll<Result<Update<E>, T>>
+    fn poll_next_update_unpin(&mut self, cx: &mut Context<'_>) -> Poll<Result<Update<E>, T>>
     where
         Self: Unpin,
     {
-        Pin::new(self).next_update(cx)
+        Pin::new(self).poll_next_update(cx)
     }
 }
 

linkerd/proxy/discover/src/from_resolve.rs

@@ -109,7 +109,7 @@ where
                 return Poll::Ready(Some(Ok(change)));
             }
 
-            match ready!(this.resolution.next_update(cx))? {
+            match ready!(this.resolution.poll_next_update(cx))? {
                 Update::Add(endpoints) => {
                     for (addr, endpoint) in endpoints.into_iter() {
                         this.active.insert(addr);

linkerd/proxy/resolve/src/map_endpoint.rs

@@ -116,7 +116,7 @@ where
 
     fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {
         let this = self.project();
-        let update = match ready!(this.resolution.next_update(cx))? {
+        let update = match ready!(this.resolution.poll_next_update(cx))? {
             resolve::Update::Add(eps) => {
                 let mut update = Vec::new();
                 for (a, ep) in eps.into_iter() {

linkerd/proxy/resolve/src/recover.rs

@@ -200,7 +200,7 @@ where
                     //
                     // Attempt recovery/backoff if the resolution fails.
 
-                    match ready!(resolution.next_update_pin(cx)) {
+                    match ready!(resolution.poll_next_update_unpin(cx)) {
                         Ok(update) => {
                             this.update_active(&update);
                             return Poll::Ready(Some(Ok(update)));
@@ -301,7 +301,7 @@ where
                 } => match ready!(resolution
                     .as_mut()
                     .expect("illegal state")
-                    .next_update_pin(cx))
+                    .poll_next_update_unpin(cx))
                 {
                     Err(e) => State::Recover {
                         error: Some(e.into()),