'Handle stream closure due to all some error while receiving data.
Raise xmpppy event specifying unsuccessfull data receive.'

def StreamBrokenHandler(self, conn, stanza):

    syn_id = stanza.getID()
    self.DEBUG(('StreamBrokenHandler    called    syn_id->%s' % syn_id), 'info')
    for sid in self._streams.keys():
        stream = self._streams[sid]
        if (stream['syn_id'] == syn_id):
            if (stream['direction'][0] == '<'):
                conn.Event(self.DBG_LINE, 'ERROR    ON    RECEIVE', stream)
            else:
                conn.Event(self.DBG_LINE, 'ERROR    ON    SEND', stream)
            del self._streams[sid]
