OpenCloud
/
MatrixSynapse
mirror of https://github.com/matrix-org/synapse
1
0
Fork 0
Code Issues Releases Wiki Activity

Update tests/replication/_base.py 

Co-authored-by: Patrick Cloke <clokep@users.noreply.github.com>
pull/8433/head
Erik Johnston 2020-10-01 18:57:17 +01:00
parent 6a0da53685
commit 8c78cdfc1b
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tests/replication/_base.py
View File

@ -224,7 +224,7 @@ class BaseMultiWorkerStreamTestCase(unittest.HomeserverTestCase):
# manually have to go and explicitly set it up each time (plus sometimes # manually have to go and explicitly set it up each time (plus sometimes
# it is impossible to write the handling explicitly in the tests). # 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( self.reactor.add_tcp_client_callback(
"1.2.3.4", "1.2.3.4",
8765, 8765,
@ -647,5 +647,5 @@ class FakeRedisPubSubProtocol(Protocol):
raise Exception("Unrecognized type for encoding redis: %r: %r", type(obj), obj) 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) self._server.remove_subscriber(self)