Add par_encode/decode to some tests

CHANGELOG.md

@@ -12,6 +12,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
  - **Breaking**: Added `CodecError::UnsupportedDataType`
  - Added `array_subset::IncompatibleArrayShapeError`
  - Added `array_subset::iter_linearised_indices_unchecked`
+ - Added parallel encoding/decoding to tests
 
 ### Changed
  - **Breaking**: `array::data_type::DataType` is now marked `#[non_exhaustive]`

src/array/codec/array_to_bytes/codec_chain.rs

@@ -503,6 +503,17 @@ mod tests {
         }
         assert_eq!(bytes, decoded);
 
+        let encoded = codec
+            .par_encode(bytes.clone(), &array_representation)
+            .unwrap();
+        let decoded = codec
+            .par_decode(encoded.clone(), &array_representation)
+            .unwrap();
+        if not_just_bytes {
+            assert_ne!(encoded, decoded);
+        }
+        assert_eq!(bytes, decoded);
+
         // println!("{} {}", encoded_chunk.len(), decoded_chunk.len());
     }
 

src/array/codec/array_to_bytes/sharding.rs

@@ -178,6 +178,18 @@ mod tests {
             .unwrap();
         assert_ne!(encoded, decoded);
         assert_eq!(bytes, decoded);
+
+        // println!("bytes {bytes:?}");
+        let encoded = codec
+            .par_encode(bytes.clone(), &array_representation)
+            .unwrap();
+        // println!("encoded {encoded:?}");
+        let decoded = codec
+            .par_decode(encoded.clone(), &array_representation)
+            .unwrap();
+        // println!("decoded {decoded:?}");
+        assert_ne!(encoded, decoded);
+        assert_eq!(bytes, decoded);
     }
 
     #[test]