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
|
from autobahn.twisted.component import Component, run
from autobahn.wamp.types import RegisterOptions
from autobahn.wamp.exception import ApplicationError
from twisted.internet.defer import inlineCallbacks, CancelledError
@inlineCallbacks
def main(reactor, session):
print("Client session={}".format(session))
d = session.call("example.foo", "some", "args")
print("Called 'example.foo': {}".format(d))
print("cancel()-ing the above Deferred")
d.cancel()
try:
res = yield d
print("somehow we got a result: {}".format(res))
except CancelledError:
print("call was canceled successfully")
print("done")
component = Component(
transports="ws://localhost:8080/auth_ws",
main=main,
realm="crossbardemo",
)
if __name__ == "__main__":
run([component]) #, log_level='debug')
|
