'Called by L{H2Stream} objects to signal completion of a response.
@param streamID: The ID of the stream to write the data to.
@type streamID: L{int}'

def endRequest(self, streamID):

    self._outboundStreamQueues[streamID].append(_END_STREAM_SENTINEL)
    self.priority.unblock(streamID)
    if (self._sendingDeferred is not None):
        d = self._sendingDeferred
        self._sendingDeferred = None
        d.callback(streamID)
