Skip to content

Commit 569ce0f

Browse files
easwarscjqzhao
authored andcommitted
grpc: add testing utilities for LB policy tests (hyperium#2380)
1 parent 52f9de8 commit 569ce0f

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

grpc/src/client/load_balancing/test_utils.rs

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -41,10 +41,9 @@ use std::{fmt::Debug, ops::Add, sync::Arc};
4141
use tokio::sync::mpsc::Sender;
4242
use tokio::sync::{mpsc, Notify};
4343
use tokio::task::AbortHandle;
44-
use tonic::metadata::MetadataMap;
4544

46-
#[derive(Debug)]
4745
pub(crate) struct EmptyMessage {}
46+
impl Message for EmptyMessage {}
4847
pub(crate) fn new_request() -> Request {
4948
Request::new(Box::pin(tokio_stream::once(
5049
Box::new(EmptyMessage {}) as Box<dyn Message>
@@ -112,7 +111,7 @@ impl Debug for TestEvent {
112111
Self::NewSubchannel(sc) => write!(f, "NewSubchannel({})", sc.address()),
113112
Self::UpdatePicker(state) => write!(f, "UpdatePicker({})", state.connectivity_state),
114113
Self::RequestResolution => write!(f, "RequestResolution"),
115-
Self::Connect(addr) => write!(f, "Connect({:?})", addr.address),
114+
Self::Connect(addr) => write!(f, "Connect({})", addr.address.to_string()),
116115
Self::ScheduleWork => write!(f, "ScheduleWork"),
117116
}
118117
}

0 commit comments

Comments
 (0)