@@ -385,7 +385,7 @@ impl AsyncPgConnection {
385
385
. flat_map ( |( bind_index, ( bytes_0, bytes_1) ) | {
386
386
std:: iter:: zip ( bytes_0. unwrap_or_default ( ) , bytes_1. unwrap_or_default ( ) )
387
387
. enumerate ( )
388
- . filter_map ( |( byte_index, bytes) | ( bytes == ( 0 , 1 ) ) . then_some ( ( bind_index, byte_index) ) )
388
+ . filter_map ( move |( byte_index, bytes) | ( bytes == ( 0 , 1 ) ) . then_some ( ( bind_index, byte_index) ) )
389
389
} )
390
390
// Avoid storing the bind collectors in the returned Future
391
391
. collect :: < Vec < _ > > ( ) ;
@@ -407,9 +407,9 @@ impl AsyncPgConnection {
407
407
// to borther with that at all
408
408
if !metadata_lookup. unresolved_types . is_empty ( ) {
409
409
let metadata_cache = & mut * metadata_cache. lock ( ) . await ;
410
- let real_oids = HashMap :: < u32 , u32 > :: new ( ) ;
410
+ let mut real_oids = HashMap :: < u32 , u32 > :: new ( ) ;
411
411
412
- for ( index, ( ref schema, ref lookup_type_name) ) in metadata_lookup. unresolved_types . into_iter ( ) . enumerate ( ) {
412
+ for ( index, ( schema, lookup_type_name) ) in metadata_lookup. unresolved_types . iter ( ) . enumerate ( ) {
413
413
// for each unresolved item
414
414
// we check whether it's arleady in the cache
415
415
// or perform a lookup and insert it into the cache
0 commit comments