equal
deleted
inserted
replaced
239 let (stream, addr) = value; |
239 let (stream, addr) = value; |
240 match layer.tls.acceptor.accept(stream).await { |
240 match layer.tls.acceptor.accept(stream).await { |
241 Ok(stream) => { |
241 Ok(stream) => { |
242 if let Some(client) = layer.create_client(ClientStream::Tls(stream), addr).await |
242 if let Some(client) = layer.create_client(ClientStream::Tls(stream), addr).await |
243 { |
243 { |
244 tokio::spawn(client.run(update_tx.clone())); |
244 tokio::spawn(client.run(update_tx)); |
245 } |
245 } |
246 } |
246 } |
247 Err(e) => { |
247 Err(e) => { |
248 warn!("Unable to establish TLS connection: {}", e); |
248 warn!("Unable to establish TLS connection: {}", e); |
249 } |
249 } |