diff --git a/integration-testing/src/flight_server_scenarios/auth_basic_proto.rs b/integration-testing/src/flight_server_scenarios/auth_basic_proto.rs index 4bef88cbe5a..361810bc244 100644 --- a/integration-testing/src/flight_server_scenarios/auth_basic_proto.rs +++ b/integration-testing/src/flight_server_scenarios/auth_basic_proto.rs @@ -31,7 +31,7 @@ impl Service { .get_bin("auth-token-bin") .and_then(|v| v.to_bytes().ok()) .and_then(|b| String::from_utf8(b.to_vec()).ok()) - .and_then(|username| (username == AUTH_USERNAME).then(|| AUTH_USERNAME.to_string())) + .and_then(|username| (username == AUTH_USERNAME).then_some(AUTH_USERNAME.to_string())) .ok_or_else(|| Status::unauthenticated("Invalid token")) } } diff --git a/src/array/boolean/iterator.rs b/src/array/boolean/iterator.rs index cc735b3a76c..a56cf9095af 100644 --- a/src/array/boolean/iterator.rs +++ b/src/array/boolean/iterator.rs @@ -22,8 +22,8 @@ impl IntoIterator for BooleanArray { fn into_iter(self) -> Self::IntoIter { let (_, values, validity) = self.into_inner(); let values = values.into_iter(); - let validity = - validity.and_then(|validity| (validity.unset_bits() > 0).then_some(validity.into_iter())); + let validity = validity + .and_then(|validity| (validity.unset_bits() > 0).then_some(validity.into_iter())); ZipValidity::new(values, validity) } } diff --git a/src/array/primitive/iterator.rs b/src/array/primitive/iterator.rs index 0ab75aa597c..8c1cdd5fb18 100644 --- a/src/array/primitive/iterator.rs +++ b/src/array/primitive/iterator.rs @@ -16,8 +16,8 @@ impl IntoIterator for PrimitiveArray { fn into_iter(self) -> Self::IntoIter { let (_, values, validity) = self.into_inner(); let values = values.into_iter(); - let validity = - validity.and_then(|validity| (validity.unset_bits() > 0).then_some(validity.into_iter())); + let validity = validity + .and_then(|validity| (validity.unset_bits() > 0).then_some(validity.into_iter())); ZipValidity::new(values, validity) } } diff --git a/tests/it/io/parquet/read_indexes.rs b/tests/it/io/parquet/read_indexes.rs index 4e41bb2baf6..462e9f8c1b4 100644 --- a/tests/it/io/parquet/read_indexes.rs +++ b/tests/it/io/parquet/read_indexes.rs @@ -120,7 +120,7 @@ fn read_with_indexes( first_field_column .iter() .zip(selection) - .filter_map(|(i, is_selected)| is_selected.then(|| *i)) + .filter_map(|(i, is_selected)| is_selected.then_some(*i)) .collect() }) })