'Notify any user streams that are interested in this room event'

def _on_new_room_event(self, event, room_stream_id, extra_users=[]):

    preserve_fn(self.appservice_handler.notify_interested_services)(room_stream_id)
    if self.federation_sender:
        preserve_fn(self.federation_sender.notify_new_events)(room_stream_id)
    if ((event.type == EventTypes.Member) and (event.membership == Membership.JOIN)):
        self._user_joined_room(event.state_key, event.room_id)
    self.on_new_event('room_key', room_stream_id, users=extra_users, rooms=[event.room_id])
