diff --git a/src/wormhole/blocking/transcribe.py b/src/wormhole/blocking/transcribe.py index 86f24c2..9a14981 100644 --- a/src/wormhole/blocking/transcribe.py +++ b/src/wormhole/blocking/transcribe.py @@ -92,7 +92,7 @@ class Channel: raise Timeout queryargs = urlencode([("appid", self._appid), ("channelid", self._channelid)]) - f = EventSourceFollower(self._relay_url+"get?%s" % queryargs, + f = EventSourceFollower(self._relay_url+"watch?%s" % queryargs, remaining) # we loop here until the connection is lost, or we see the # message we want diff --git a/src/wormhole/twisted/transcribe.py b/src/wormhole/twisted/transcribe.py index 044d217..db4a154 100644 --- a/src/wormhole/twisted/transcribe.py +++ b/src/wormhole/twisted/transcribe.py @@ -140,7 +140,7 @@ class Channel: # TODO: use agent=self._agent queryargs = urlencode([("appid", self._appid), ("channelid", self._channelid)]) - es = ReconnectingEventSource(self._relay_url+"get?%s" % queryargs, + es = ReconnectingEventSource(self._relay_url+"watch?%s" % queryargs, _handle) es.startService() # TODO: .setServiceParent(self) es.activate()