We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent edca754 commit e7b253aCopy full SHA for e7b253a
src/primary/traits/base_server.rs
@@ -39,8 +39,19 @@ pub trait BaseServer: Send {
39
let (shutdown_tx, mut shutdown_rx) = mpsc::channel::<()>(1);
40
41
let port = Self::port(options.clone());
42
+ let connection_message = format!("[{}] is started on port {}", Self::server_name(), port);
43
let listener = TcpListener::bind(format!("127.0.0.1:{}", port)).await?;
- crate::debug!("[{}] is started on port {}", Self::server_name(), port);
44
+ crate::debug!("{}", connection_message);
45
+
46
+ if options.sender.is_some() {
47
+ let sender = options.sender.clone().unwrap();
48
+ sender
49
+ .broadcast(ClientHandlerOutput::SuccessMessage(
50
+ connection_message,
51
+ None,
52
+ ))
53
+ .await?;
54
+ }
55
56
loop {
57
tokio::select! {
0 commit comments