balance: Fix tokio-sync channel poll fn
This commit is contained in:
parent
bd62f64d6c
commit
67a9e27177
|
@ -16,7 +16,7 @@
|
||||||
|
|
||||||
use super::p2c::Balance;
|
use super::p2c::Balance;
|
||||||
use crate::error;
|
use crate::error;
|
||||||
use futures_core::{ready, Stream};
|
use futures_core::ready;
|
||||||
use pin_project::pin_project;
|
use pin_project::pin_project;
|
||||||
use slab::Slab;
|
use slab::Slab;
|
||||||
use std::{
|
use std::{
|
||||||
|
@ -78,7 +78,7 @@ where
|
||||||
) -> Poll<Result<Change<Self::Key, Self::Service>, Self::Error>> {
|
) -> Poll<Result<Change<Self::Key, Self::Service>, Self::Error>> {
|
||||||
let mut this = self.project();
|
let mut this = self.project();
|
||||||
|
|
||||||
while let Poll::Ready(Some(sid)) = this.died_rx.as_mut().poll_next(cx) {
|
while let Poll::Ready(Some(sid)) = this.died_rx.as_mut().poll_recv(cx) {
|
||||||
this.services.remove(sid);
|
this.services.remove(sid);
|
||||||
tracing::trace!(
|
tracing::trace!(
|
||||||
pool.services = this.services.len(),
|
pool.services = this.services.len(),
|
||||||
|
|
Loading…
Reference in New Issue