From c59e9048398380d8275dec3f76a08eba228f861b Mon Sep 17 00:00:00 2001
From: Erik Johnston <erik@matrix.org>
Date: Thu, 18 Jun 2015 10:52:00 +0100
Subject: [PATCH] Mark as notified

---
 synapse/notifier.py | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/synapse/notifier.py b/synapse/notifier.py
index 25357f7858..2b1fdc0ab6 100644
--- a/synapse/notifier.py
+++ b/synapse/notifier.py
@@ -51,6 +51,7 @@ class _NotificationListener(object):
         self.deferred = deferred
         self.created = int(time.time() * 1000)
         self.timeout = timeout
+        self.notified = False
 
     def notified(self):
         return self.deferred.called
@@ -58,6 +59,7 @@ class _NotificationListener(object):
     def notify(self, token):
         """ Inform whoever is listening about the new events.
         """
+        self.notified = True
         try:
             self.deferred.callback(token)
         except defer.AlreadyCalledError: