(self, code, reason=None)
Puts a :exc:`StopIteration` as a message into the
        `messages` queue.
Puts a :exc:`StopIteration` as a message into the
        `messages` queue.
Puts a : exc : StopIteration as a message into the messages queue .
def closed(self, code, reason=None):
        """
        Puts a :exc:`StopIteration` as a message into the
        `messages` queue.
        """
        # When the connection is closed, put a StopIteration
        # on the message queue to signal there's nothing left
        # to wait for
        self.messages.put(StopIteration)
def closed ( self , code , reason = None ) : # When the connection is closed, put a StopIteration # on the message queue to signal there's nothing left # to wait for self . messages . put ( StopIteration )