Alias for aclose(), for backwards compatibility
(self)
| 1080 | |
| 1081 | @deprecated_function(version="5.0.1", reason="Use aclose() instead", name="reset") |
| 1082 | async def reset(self) -> None: |
| 1083 | """Alias for aclose(), for backwards compatibility""" |
| 1084 | await self.aclose() |
| 1085 | |
| 1086 | async def _resubscribe(self, subscribed, subscribe_fn) -> None: |
| 1087 | # Replay handler-backed subscriptions as positional Subscription objects |