'Call when there is no more data to send.'

def end_of_object_data(self, **kwargs):

    if (self.state == DATA_SENT):
        raise ValueError('called    end_of_object_data    twice')
    self.queue.put('')
    self.state = DATA_SENT
