@@ -246,9 +246,7 @@ impl KVStore for VssStore {
246246 let secondary_namespace = secondary_namespace. to_string ( ) ;
247247 let key = key. to_string ( ) ;
248248 let inner = Arc :: clone ( & self . inner ) ;
249- Box :: pin (
250- async move { inner. read_internal ( primary_namespace, secondary_namespace, key) . await } ,
251- )
249+ async move { inner. read_internal ( primary_namespace, secondary_namespace, key) . await }
252250 }
253251 fn write (
254252 & self , primary_namespace : & str , secondary_namespace : & str , key : & str , buf : Vec < u8 > ,
@@ -259,7 +257,7 @@ impl KVStore for VssStore {
259257 let secondary_namespace = secondary_namespace. to_string ( ) ;
260258 let key = key. to_string ( ) ;
261259 let inner = Arc :: clone ( & self . inner ) ;
262- Box :: pin ( async move {
260+ async move {
263261 inner
264262 . write_internal (
265263 inner_lock_ref,
@@ -271,7 +269,7 @@ impl KVStore for VssStore {
271269 buf,
272270 )
273271 . await
274- } )
272+ }
275273 }
276274 fn remove (
277275 & self , primary_namespace : & str , secondary_namespace : & str , key : & str , _lazy : bool ,
@@ -282,7 +280,7 @@ impl KVStore for VssStore {
282280 let secondary_namespace = secondary_namespace. to_string ( ) ;
283281 let key = key. to_string ( ) ;
284282 let inner = Arc :: clone ( & self . inner ) ;
285- Box :: pin ( async move {
283+ async move {
286284 inner
287285 . remove_internal (
288286 inner_lock_ref,
@@ -293,15 +291,15 @@ impl KVStore for VssStore {
293291 key,
294292 )
295293 . await
296- } )
294+ }
297295 }
298296 fn list (
299297 & self , primary_namespace : & str , secondary_namespace : & str ,
300298 ) -> impl Future < Output = Result < Vec < String > , io:: Error > > + ' static + Send {
301299 let primary_namespace = primary_namespace. to_string ( ) ;
302300 let secondary_namespace = secondary_namespace. to_string ( ) ;
303301 let inner = Arc :: clone ( & self . inner ) ;
304- Box :: pin ( async move { inner. list_internal ( primary_namespace, secondary_namespace) . await } )
302+ async move { inner. list_internal ( primary_namespace, secondary_namespace) . await }
305303 }
306304}
307305
0 commit comments