clients: use "watch" endpoint, not "get"
This commit is contained in:
parent
2318c94169
commit
1d6c3d1f96
|
@ -92,7 +92,7 @@ class Channel:
|
||||||
raise Timeout
|
raise Timeout
|
||||||
queryargs = urlencode([("appid", self._appid),
|
queryargs = urlencode([("appid", self._appid),
|
||||||
("channelid", self._channelid)])
|
("channelid", self._channelid)])
|
||||||
f = EventSourceFollower(self._relay_url+"get?%s" % queryargs,
|
f = EventSourceFollower(self._relay_url+"watch?%s" % queryargs,
|
||||||
remaining)
|
remaining)
|
||||||
# we loop here until the connection is lost, or we see the
|
# we loop here until the connection is lost, or we see the
|
||||||
# message we want
|
# message we want
|
||||||
|
|
|
@ -140,7 +140,7 @@ class Channel:
|
||||||
# TODO: use agent=self._agent
|
# TODO: use agent=self._agent
|
||||||
queryargs = urlencode([("appid", self._appid),
|
queryargs = urlencode([("appid", self._appid),
|
||||||
("channelid", self._channelid)])
|
("channelid", self._channelid)])
|
||||||
es = ReconnectingEventSource(self._relay_url+"get?%s" % queryargs,
|
es = ReconnectingEventSource(self._relay_url+"watch?%s" % queryargs,
|
||||||
_handle)
|
_handle)
|
||||||
es.startService() # TODO: .setServiceParent(self)
|
es.startService() # TODO: .setServiceParent(self)
|
||||||
es.activate()
|
es.activate()
|
||||||
|
|
Loading…
Reference in New Issue
Block a user