-
Notifications
You must be signed in to change notification settings - Fork 0
Home
thehub edited this page Sep 13, 2010
·
2 revisions
import bases
class TestSubscriber(bases.SubscriberBase):
def onHelloWorldRequest(self, x):
if not isinstance(x, int): x = 1
out = "Hello world" * x
print out
return out
onHelloWorldRequest.block = True
Add following somewhere before we initialize Pyro server
testsubscriber = subscribers.testsubscriber.TestSubscriber("testsubscriber")
- Subscriber added
syncer.onHelloWorldRequest.addSubscriber(testsubscriber)- Event and Subscriber
python daemon.py
Did you notice “found testsubscriber”?
>>> import syncer
>>> import syncer.client
>>>
>>> sessions = {}
>>> sessiongetter = lambda: sessions
>>> syncerclient = syncer.client.SyncerClient("MyApp", sessiongetter)
>>>
>>> tr_id, res = syncerclient.onHelloWorldRequest(2)
>>> print res