From 8c78cdfc1bf9b20fa82d7870c24795d5ebf2c741 Mon Sep 17 00:00:00 2001 From: Erik Johnston Date: Thu, 1 Oct 2020 18:57:17 +0100 Subject: [PATCH] Update tests/replication/_base.py Co-authored-by: Patrick Cloke --- tests/replication/_base.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/tests/replication/_base.py b/tests/replication/_base.py index d381e7a942..81ea985b9f 100644 --- a/tests/replication/_base.py +++ b/tests/replication/_base.py @@ -224,7 +224,7 @@ class BaseMultiWorkerStreamTestCase(unittest.HomeserverTestCase): # manually have to go and explicitly set it up each time (plus sometimes # it is impossible to write the handling explicitly in the tests). # - # This sets registers the master replication listener: + # Register the master replication listener: self.reactor.add_tcp_client_callback( "1.2.3.4", 8765, @@ -647,5 +647,5 @@ class FakeRedisPubSubProtocol(Protocol): raise Exception("Unrecognized type for encoding redis: %r: %r", type(obj), obj) - def connectionList(self, reason): + def connectionLost(self, reason): self._server.remove_subscriber(self)