'Used by handlers to inform the notifier something has happened
in the room, room event wise.
This triggers the notifier to wake up any listeners that are
listening to the room, and any listeners for the users in the
`extra_users` param.
The events can be peristed out of order. The notifier will wait
until all previous events have been persisted before notifying
the client streams.'

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

    self.pending_new_room_events.append((room_stream_id, event, extra_users))
    self._notify_pending_new_room_events(max_room_stream_id)
    self.notify_replication()
