[issue1736190] asyncore/asynchat patches

Doc/library/asynchat.rst

 
 :mod:`asynchat` --- Asynchronous socket command/response handler
 ================================================================
 
 .. module:: asynchat
    :synopsis: Support for asynchronous command/response protocols.
 .. moduleauthor:: Sam Rushing <rushing@nightmare.com>
 .. sectionauthor:: Steve Holden <sholden@holdenweb.com>
 
 
@@ skipping 61 matching lines @@
 
    Pushes a ``None`` on to the producer fifo. When this producer is popped off
    the fifo it causes the channel to be closed.
 
 
 .. method:: async_chat.collect_incoming_data(data)
 
    Called with *data* holding an arbitrary amount of received data.  The
    default method, which must be overridden, raises a
    :exc:`NotImplementedError` exception.
+
+
+.. method:: async_chat._collect_incoming_data(data)
+
+   Sample implementation of a data collection rutine to be used in conjunction
+   with :meth:`_get_data` in a user-specified :meth:`found_terminator`.
 
 
 .. method:: async_chat.discard_buffers()
 
    In emergencies this method will discard any data held in the input and/or
    output buffers and the producer fifo.
 
 
 .. method:: async_chat.found_terminator()
 
    Called when the incoming data stream  matches the termination condition set
    by :meth:`set_terminator`. The default method, which must be overridden,
    raises a :exc:`NotImplementedError` exception. The buffered input data
    should be available via an instance attribute.
+
+
+.. method:: async_chat._get_data()
+
+   Will return and clear the data received with the sample
+   :meth:`_collect_incoming_data` implementation.
 
 
 .. method:: async_chat.get_terminator()
 
    Returns the current terminator for the channel.
 
 
 .. method:: async_chat.handle_close()
 
    Called when the channel is closed. The default method silently closes the
@@ skipping 187 matching lines @@
                else:
                    self.handling = True
                    self.set_terminator(None)
                    self.handle_request()
            elif not self.handling:
                self.set_terminator(None) # browsers sometimes over-send
                self.cgi_data = parse(self.headers, "".join(self.ibuffer))
                self.handling = True
                self.ibuffer = []
                self.handle_request()