Revert "Fixup pusher pool notifications"

This reverts commit e7fd336a53.
This commit is contained in:
Erik Johnston 2020-09-09 16:19:22 +01:00
parent e7fd336a53
commit dc9dcdbd59
7 changed files with 8 additions and 23 deletions

View file

@ -2970,7 +2970,7 @@ class FederationHandler(BaseHandler):
event, event_stream_id, max_stream_id, extra_users=extra_users
)
await self.pusher_pool.on_new_notifications(max_stream_id)
await self.pusher_pool.on_new_notifications(event_stream_id, max_stream_id)
async def _clean_room_for_join(self, room_id: str) -> None:
"""Called to clean up any data in DB for a given room, ready for the