async

Author: normanrz

src/zarr/codecs/_v2.py

@@ -1,5 +1,6 @@
 from __future__ import annotations
 
+import asyncio
 from dataclasses import dataclass
 from typing import TYPE_CHECKING
 
@@ -32,14 +33,14 @@ async def _decode_single(
         cdata = chunk_bytes.as_array_like()
         # decompress
         if self.compressor:
-            chunk = self.compressor.decode(cdata)
+            chunk = await asyncio.to_thread(self.compressor.decode, cdata)
         else:
             chunk = cdata
 
         # apply filters
         if self.filters:
             for f in reversed(self.filters):
-                chunk = f.decode(chunk)
+                chunk = await asyncio.to_thread(f.decode, chunk)
 
         # view as numpy array with correct dtype
         chunk = ensure_ndarray_like(chunk)
@@ -71,15 +72,15 @@ async def _encode_single(
         # apply filters
         if self.filters:
             for f in self.filters:
-                chunk = f.encode(chunk)
+                chunk = await asyncio.to_thread(f.encode, chunk)
 
         # check object encoding
         if ensure_ndarray_like(chunk).dtype == object:
             raise RuntimeError("cannot write object array without object codec")
 
         # compress
         if self.compressor:
-            cdata = self.compressor.encode(chunk)
+            cdata = await asyncio.to_thread(self.compressor.encode, chunk)
         else:
             cdata = chunk