'Manage flow control windows.
Streams that are blocked on flow control will register themselves with
the connection. This will fire deferreds that wake those streams up and
allow them to continue processing.
@param event: The Hyper-h2 event that encodes information about the
flow control window change.
@type event: L{h2.events.WindowUpdated}'

def _handleWindowUpdate(self, event):

    streamID = event.stream_id
    if streamID:
        if (not self._streamIsActive(streamID)):
            return
        if self._outboundStreamQueues.get(streamID):
            self.priority.unblock(streamID)
        self.streams[streamID].windowUpdated()
    else:
        for stream in self.streams.values():
            stream.windowUpdated()
            if self._outboundStreamQueues.get(stream.streamID):
                self.priority.unblock(stream.streamID)
