async to_obj

src/msglc/reader.py

@@ -35,6 +35,16 @@ def to_obj(v):
     return v.to_obj() if isinstance(v, LazyItem) else v
 
 
+async def async_to_obj(v):
+    """
+    Ensure the given value is JSON serializable.
+    """
+    if isinstance(v, LazyItem):
+        return await asyncio.to_thread(v.to_obj)
+
+    return v
+
+
 async def async_get(v, key):
     if isinstance(v, LazyItem):
         return await v.async_get(key)

tests/test_msglc.py

@@ -20,7 +20,7 @@
 
 from msglc import LazyWriter, FileInfo, combine, append
 from msglc.config import config, increment_gc_counter, decrement_gc_counter, configure
-from msglc.reader import LazyStats, LazyReader
+from msglc.reader import LazyStats, LazyReader, async_to_obj
 from msglc.utility import MockIO
 
 
@@ -142,6 +142,7 @@ async def test_async_msglc(monkeypatch, tmpdir, json_before, json_after, target,
                 assert await reader.async_read("glossary/empty_list") == []
                 assert await reader.async_read("glossary/none_list/0") is None
                 assert await reader.async_read() == json_after
+                assert await async_to_obj(reader) == json_after
                 assert reader == json_after
 
                 dict_container = await reader.async_read("glossary/GlossDiv")