async: enable retry logic also for response bodies

fsspec · Mar 11, 2022 · 5c9bca4 · 5c9bca4
1 parent 5286e26
commit 5c9bca4
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/ipfsspec/async_ipfs.py b/ipfsspec/async_ipfs.py
@@ -227,6 +227,12 @@ async def cid_head(self, path, session, headers=None, **kwargs):
     async def cid_get(self, path, session, headers=None, **kwargs):
         return await self._gw_op(lambda gw: gw.cid_get(path, session, headers=headers, **kwargs))
 
+    async def cat(self, path, session):
+        return await self._gw_op(lambda gw: gw.cat(path, session))
+
+    async def ls(self, path, session):
+        return await self._gw_op(lambda gw: gw.ls(path, session))
+
     def state_report(self):
         return "\n".join(f"{s.next_request_time}, {gw}" for s, gw in self.gws)