Deduplicate joins

This commit is contained in:
Erik Johnston 2016-04-06 15:44:22 +01:00
parent 87a30890a3
commit af03ecf352
4 changed files with 118 additions and 1 deletions

View file

@ -35,7 +35,7 @@ class ResponseCache(object):
return None
def set(self, key, deferred):
result = ObservableDeferred(deferred)
result = ObservableDeferred(deferred, consumeErrors=True)
self.pending_result_cache[key] = result
def remove(r):