def handle_read (self):
    try:
        data = self.recv (self.ac_in_buffer_size)
    except socket.error, why:
        self.handle_error()
        return
        
    if hasattr(self.socket, 'ssl_version'):
    # Fix for SSL wrapped sockets, checks if there is any data pending in the
    # SSL Socket's internal buffer and recv's it before contining.
        ssl_data_remainder = ''
        amount_of_data_left_over = self.socket.pending()
        while amount_of_data_left_over > 0: #  while the ssl socket still has some data pending
            try:
                ssl_data_remainder += self.recv(amount_of_data_left_over) # get the remaining data
            except socket.error, why:
                self.handle_error()
                return
            amount_of_data_left_over = self.socket.pending()  # check if there is anymore remaining
        data += ssl_data_remainder  # add the remainder to the data
    self.ac_in_buffer = self.ac_in_buffer + data

    # Continue to search for self.terminator in self.ac_in_buffer,
    # while calling self.collect_incoming_data.  The while loop
    # is necessary because we might read several data+terminator
    # combos with a single recv(4096).

    while self.ac_in_buffer:
        lb = len(self.ac_in_buffer)
        terminator = self.get_terminator()
        if not terminator:
            # no terminator, collect it all
            self.collect_incoming_data (self.ac_in_buffer)
            self.ac_in_buffer = ''
        elif isinstance(terminator, int) or isinstance(terminator, long):
            # numeric terminator
            n = terminator
            if lb < n:
                self.collect_incoming_data (self.ac_in_buffer)
                self.ac_in_buffer = ''
                self.terminator = self.terminator - lb
            else:
                self.collect_incoming_data (self.ac_in_buffer[:n])
                self.ac_in_buffer = self.ac_in_buffer[n:]
                self.terminator = 0
                self.found_terminator()
        else:
            # 3 cases:
            # 1) end of buffer matches terminator exactly:
            #    collect data, transition
            # 2) end of buffer matches some prefix:
            #    collect data to the prefix
            # 3) end of buffer does not match any prefix:
            #    collect data
            terminator_len = len(terminator)
            index = self.ac_in_buffer.find(terminator)
            if index != -1:
                # we found the terminator
                if index > 0:
                    # don't bother reporting the empty string (source of subtle bugs)
                    self.collect_incoming_data (self.ac_in_buffer[:index])
                self.ac_in_buffer = self.ac_in_buffer[index+terminator_len:]
                # This does the Right Thing if the terminator is changed here.
                self.found_terminator()
            else:
                # check for a prefix of the terminator
                index = find_prefix_at_end (self.ac_in_buffer, terminator)
                if index:
                    if index != lb:
                        # we found a prefix, collect up to the prefix
                        self.collect_incoming_data (self.ac_in_buffer[:-index])
                        self.ac_in_buffer = self.ac_in_buffer[-index:]
                    break
                else:
                    # no prefix, collect it all
                    self.collect_incoming_data (self.ac_in_buffer)
                    self.ac_in_buffer = ''