'@see: L{IPushProducer.resumeProducing}'

def resumeProducing(self):

    self.producing = True
    consumedLength = 0
    while (self.producing and self._inboundDataBuffer):
        (chunk, flowControlledLength) = self._inboundDataBuffer.popleft()
        if (chunk is _END_STREAM_SENTINEL):
            self.requestComplete()
        else:
            consumedLength += flowControlledLength
            self._request.handleContentChunk(chunk)
    self._conn.openStreamWindow(self.streamID, consumedLength)
