You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
On the following code if the subscription is lost, the instantiated client will no longer be able to receive the replies of any request because the subscription is not recreated.
This behavior wasn't happening on the old style request.
`async def _request_new_style(
self,
subject: str,
payload: bytes,
timeout: float = 1,
headers: Optional[Dict[str, Any]] = None,
) -> Msg:
if self.is_draining_pubs:
raise errors.ConnectionDrainingError
if not self._resp_sub_prefix:
await self._init_request_sub()
assert self._resp_sub_prefix`
Expected behavior
if a subscription is lost a new one should be created.
Observed behavior
On the following code if the subscription is lost, the instantiated client will no longer be able to receive the replies of any request because the subscription is not recreated.
This behavior wasn't happening on the old style request.
`async def _request_new_style(
self,
subject: str,
payload: bytes,
timeout: float = 1,
headers: Optional[Dict[str, Any]] = None,
) -> Msg:
if self.is_draining_pubs:
raise errors.ConnectionDrainingError
Expected behavior
if a subscription is lost a new one should be created.
Server and client version
https://github.com/nats-io/nats.py/releases/tag/v2.9.0
Host environment
No response
Steps to reproduce
I wasn't able to reproduce how I lost a subscription, but it already happened on some of our clients.
The text was updated successfully, but these errors were encountered: