We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c1b2396 commit 80fc973Copy full SHA for 80fc973
grpc/src/client/load_balancing/test_utils.rs
@@ -41,10 +41,9 @@ use std::{fmt::Debug, ops::Add, sync::Arc};
41
use tokio::sync::mpsc::Sender;
42
use tokio::sync::{mpsc, Notify};
43
use tokio::task::AbortHandle;
44
-use tonic::metadata::MetadataMap;
45
46
-#[derive(Debug)]
47
pub(crate) struct EmptyMessage {}
+impl Message for EmptyMessage {}
48
pub(crate) fn new_request() -> Request {
49
Request::new(Box::pin(tokio_stream::once(
50
Box::new(EmptyMessage {}) as Box<dyn Message>
@@ -112,7 +111,7 @@ impl Debug for TestEvent {
112
111
Self::NewSubchannel(sc) => write!(f, "NewSubchannel({})", sc.address()),
113
Self::UpdatePicker(state) => write!(f, "UpdatePicker({})", state.connectivity_state),
114
Self::RequestResolution => write!(f, "RequestResolution"),
115
- Self::Connect(addr) => write!(f, "Connect({:?})", addr.address),
+ Self::Connect(addr) => write!(f, "Connect({})", addr.address.to_string()),
116
Self::ScheduleWork => write!(f, "ScheduleWork"),
117
}
118
0 commit comments