Mercurial > code > home > repos > homeauto

comparison service/reasoning/twisted_sse_demo/eventsource.py @ 1106:fe53ca09febc

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
big rewrites in sse_collector Ignore-this: 3b6278a0cfc57aa686ed39d411fdc35f darcs-hash:d25124b5e0d3c4729ea55530cd3b3064f2af68a7
author drewp <drewp@bigasterisk.com>
date Sun, 28 Aug 2016 18:11:34 -0700
parents b84e956771fc
children
comparison
equal deleted inserted replaced
1105:c8233f4b59cb 1106:fe53ca09febc
4 from twisted.web.client import Agent 4 from twisted.web.client import Agent
5 from twisted.web.http_headers import Headers 5 from twisted.web.http_headers import Headers
6 6
7 from sse_client import EventSourceProtocol 7 from sse_client import EventSourceProtocol
8 8
9 #setup() 9 setup()
10 10
11 11
12 class EventSource(object): 12 class EventSource(object):
13 """ 13 """
14 The main EventSource class 14 The main EventSource class
18 self.protocol = EventSourceProtocol() 18 self.protocol = EventSourceProtocol()
19 self.errorHandler = None 19 self.errorHandler = None
20 self.stashedError = None 20 self.stashedError = None
21 self.connect() 21 self.connect()
22 22
23 #@run_in_reactor 23 @run_in_reactor
24 def connect(self): 24 def connect(self):
25 """ 25 """
26 Connect to the event source URL 26 Connect to the event source URL
27 """ 27 """
28 agent = Agent(reactor) 28 agent = Agent(reactor)