1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
|
from twisted.internet.task import react
from twisted.internet.defer import inlineCallbacks as coroutine
from autobahn.twisted.wamp import Session
from autobahn.twisted.connection import Connection
class MySession(Session):
@coroutine
def on_join(self, details):
print("on_join: {}".format(details))
def add2(a, b):
return a + b
yield self.register(add2, u'com.example.add2')
try:
res = yield self.call(u'com.example.add2', 2, 3)
print("result: {}".format(res))
except Exception as e:
print("error: {}".format(e))
finally:
print('leaving ..')
#self.leave()
def on_leave(self, details):
print('on_leave xx: {}'.format(details))
self.disconnect()
def on_disconnect(self):
print('on_disconnect')
if __name__ == '__main__':
transports = u'ws://localhost:8080/ws'
connection = Connection(transports=transports)
connection.session = MySession
react(connection.start)
|
