From 5c9bca41ee33ab69ff15bbd258b8e641e93583cf Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Tobias=20K=C3=B6lling?= Date: Fri, 11 Mar 2022 23:10:11 +0100 Subject: [PATCH] async: enable retry logic also for response bodies --- ipfsspec/async_ipfs.py | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/ipfsspec/async_ipfs.py b/ipfsspec/async_ipfs.py index ef1cbe6..aad28c7 100644 --- 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)