File tree 2 files changed +3
-5
lines changed
2 files changed +3
-5
lines changed Original file line number Diff line number Diff line change @@ -161,11 +161,10 @@ where
161
161
}
162
162
}
163
163
164
- impl < ' a , D > Drop for Cron < ' a , D >
164
+ impl < D > Drop for Cron < ' _ , D >
165
165
where
166
166
D : Driver + Send + Sync ,
167
167
{
168
- #[ allow( unused_must_use) ]
169
168
fn drop ( & mut self ) {
170
169
self . node_pool . stop ( ) ;
171
170
}
Original file line number Diff line number Diff line change 1
- use std:: sync:: Arc ;
2
1
use std:: sync:: atomic:: { AtomicBool , AtomicU8 } ;
2
+ use std:: sync:: Arc ;
3
3
4
4
use thiserror:: Error ;
5
5
use tokio:: sync:: RwLock ;
@@ -116,7 +116,7 @@ where
116
116
}
117
117
}
118
118
119
- pub async fn stop ( & self ) {
119
+ pub fn stop ( & self ) {
120
120
self . stop . store ( true , std:: sync:: atomic:: Ordering :: SeqCst ) ;
121
121
}
122
122
}
@@ -125,7 +125,6 @@ impl<D> Drop for NodePool<D>
125
125
where
126
126
D : Driver + Send + Sync ,
127
127
{
128
- #[ allow( unused_must_use) ]
129
128
fn drop ( & mut self ) {
130
129
self . stop ( ) ;
131
130
}
You can’t perform that action at this time.
0 commit comments