nats/aio/client.py
def unsubscribe(self, ssid, max_msgs=0):
        """
        Takes a subscription sequence id and removes the subscription
        from the client, optionally after receiving more than max_msgs.
        """
        if self.is_closed:
            raise ErrConnectionClosed
        if self.is_draining:
            raise ErrConnectionDraining

        self._remove_sub(ssid, max_msgs)

        # We will send these for all subs when we reconnect anyway,
        # so that we can suppress here.
        if not self.is_reconnecting:
            yield from self.auto_unsubscribe(ssid, max_msgs)
def unsubscribe(self, ssid, max_msgs=0):
        if self.is_closed:
            raise ErrConnectionClosed
        if self.is_draining:
            raise ErrConnectionDraining

        self._remove_sub(ssid, max_msgs)

        # We will send these for all subs when we reconnect anyway,
        # so that we can suppress here.
        if not self.is_reconnecting:
            yield from self.auto_unsubscribe(ssid, max_msgs)
def unsubscribe ( self , ssid , max_msgs = 0 ) : if self . is_closed : raise ErrConnectionClosed if self . is_draining : raise ErrConnectionDraining self . _remove_sub ( ssid , max_msgs ) # We will send these for all subs when we reconnect anyway, # so that we can suppress here. if not self . is_reconnecting : yield from self . auto_unsubscribe ( ssid , max_msgs )
Takes a subscription sequence id and removes the subscription
        from the client, optionally after receiving more than max_msgs.
Takes a subscription sequence id and removes the subscription from the client optionally after receiving more than max_msgs .