From 1477d1ccdbf98827e3959cb2d04ec987e31a23e3 Mon Sep 17 00:00:00 2001 From: Kerem Turgutlu Date: Thu, 4 Jun 2026 18:02:13 +0300 Subject: [PATCH] dict2obj --- fastspec/oapi.py | 4 ++-- nbs/04_oapi.ipynb | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/fastspec/oapi.py b/fastspec/oapi.py index fa0af8f..3a60a1e 100644 --- a/fastspec/oapi.py +++ b/fastspec/oapi.py @@ -168,7 +168,7 @@ def _raise_with_context(self:OpFunc, exc:Exception, *, endpoint:str, route:Optio @delegates(AsyncTransport.request) # files, raw async def _request(self:OpFunc, url, *, headers=None, query=None, body=None, route=None, **kwargs): "Execute an HTTP request and return decoded response." - try: return await self.client.request(self.verb, url, headers=headers, params=query, json_data=body, **kwargs) + try: return dict2obj(await self.client.request(self.verb, url, headers=headers, params=query, json_data=body, **kwargs)) except Exception as e: self._raise_with_context(e, endpoint='', route=route, query=query, body=body) @patch @@ -176,7 +176,7 @@ async def _request(self:OpFunc, url, *, headers=None, query=None, body=None, rou async def _stream(self:OpFunc, url, *, headers=None, query=None, body=None, route=None, **kwargs): "Execute an SSE request yielding parsed JSON events." try: - async for ev in self.client.stream(self.verb, url, headers=headers, params=query, json_data=body, **kwargs): yield ev + async for ev in self.client.stream(self.verb, url, headers=headers, params=query, json_data=body, **kwargs): yield dict2obj(ev) except Exception as e: self._raise_with_context(e, endpoint='', route=route, query=query, body=body) # %% ../nbs/04_oapi.ipynb #0296d943 diff --git a/nbs/04_oapi.ipynb b/nbs/04_oapi.ipynb index e6ad905..4103d24 100644 --- a/nbs/04_oapi.ipynb +++ b/nbs/04_oapi.ipynb @@ -1115,7 +1115,7 @@ "@delegates(AsyncTransport.request) # files, raw\n", "async def _request(self:OpFunc, url, *, headers=None, query=None, body=None, route=None, **kwargs):\n", " \"Execute an HTTP request and return decoded response.\"\n", - " try: return await self.client.request(self.verb, url, headers=headers, params=query, json_data=body, **kwargs)\n", + " try: return dict2obj(await self.client.request(self.verb, url, headers=headers, params=query, json_data=body, **kwargs))\n", " except Exception as e: self._raise_with_context(e, endpoint='', route=route, query=query, body=body)\n", "\n", "@patch\n", @@ -1123,7 +1123,7 @@ "async def _stream(self:OpFunc, url, *, headers=None, query=None, body=None, route=None, **kwargs):\n", " \"Execute an SSE request yielding parsed JSON events.\"\n", " try:\n", - " async for ev in self.client.stream(self.verb, url, headers=headers, params=query, json_data=body, **kwargs): yield ev\n", + " async for ev in self.client.stream(self.verb, url, headers=headers, params=query, json_data=body, **kwargs): yield dict2obj(ev)\n", " except Exception as e: self._raise_with_context(e, endpoint='', route=route, query=query, body=body)" ] },