90 |
// all thread managed resources should be dropped at this point
|
91 |
#[allow(clippy::let_underscore_future)]
|
92 |
let _ = thread_stop_tx.send(());
|
298 |
// signal server to stop
|
299 |
#[allow(clippy::let_underscore_future)]
|
300 |
let _ = self.server.stop(true);
|
715 |
#[allow(clippy::let_underscore_future)]
|
716 |
let _ = init_service(my_app());
|
72 |
// allow response to be started while this is processing
|
73 |
#[allow(clippy::let_underscore_future)]
|
74 |
let _ = tokio::spawn(async move {
|
100 |
// allow response to be started while this is processing
|
101 |
#[allow(clippy::let_underscore_future)]
|
102 |
let _ = tokio::spawn(async move {
|
18 |
// do not wait for this task to finish before sending response
|
19 |
#[allow(clippy::let_underscore_future)]
|
20 |
let _ = web::block(move || {
|
917 |
#[allow(path_statements, clippy::let_underscore_future, clippy::no_effect)]
|
918 |
async fn associated2(&self) {
|
940 |
#[allow(path_statements, clippy::let_underscore_future, clippy::no_effect)]
|
941 |
async fn associated2(&self) {
|
1382 |
#[allow(path_statements, clippy::let_underscore_future, clippy::no_effect)]
|
1383 |
async fn associated2(&self) {
|
1405 |
#[allow(path_statements, clippy::let_underscore_future, clippy::no_effect)]
|
1406 |
async fn associated2(&self) {
|
570 |
#[allow(clippy::let_underscore_future)]
|
571 |
let _ = req.send_body("");
|
512 |
#[allow(clippy::let_underscore_future)]
|
513 |
let _ = req.connect();
|
383 |
#[allow(clippy::let_underscore_future)]
|
384 |
#[test]
|
389 |
#[allow(clippy::let_underscore_future)]
|
390 |
#[test]
|
34 |
#[allow(clippy::let_underscore_future)]
|
35 |
#[stream(item = i32)]
|
60 |
Some((idx, res)) => {
|
61 |
#[allow(clippy::let_underscore_future)]
|
62 |
let _ = self.inner.swap_remove(idx);
|
255 |
let metrics_count = state.metrics.state_change_count;
|
256 |
#[allow(clippy::let_underscore_future)]
|
257 |
let _ = myself.send_after(self.time_slice, move || {
|
281 |
let metrics_count = state.metrics.state_change_count;
|
282 |
#[allow(clippy::let_underscore_future)]
|
283 |
let _ = myself.send_after(self.time_slice, move || {
|
369 |
// kick off a background task to reply to the channel request, threading the tag and who to reply to
|
370 |
#[allow(clippy::let_underscore_future)]
|
371 |
let _ = ractor::concurrency::spawn(async move {
|
686 |
if let Some(tcp) = &self.tcp {
|
687 |
#[allow(clippy::let_underscore_future)]
|
688 |
let _ = tcp.send_after(Self::get_send_delay(), || {
|