openstack
/
deb-python-autobahn
Code Issues Proposed changes

@coroutine -> async def and "yield from" -> await

This commit is contained in:
meejah 2016-08-19 15:01:54 -06:00
parent 6b49bec8e4
commit c12a5a6125
34 changed files with 116 additions and 158 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
examples/asyncio/wamp/overview/backend.py
View File

@ -4,20 +4,20 @@ from autobahn.asyncio.wamp import ApplicationSession, ApplicationRunner
class MyComponent(ApplicationSession):
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
# a remote procedure; see frontend.py for a Python front-end
# that calls this. Any language with WAMP bindings can now call
# this procedure if its connected to the same router and realm.
def add2(x, y):
return x + y
yield from self.register(add2, u'com.myapp.add2')
reg = await self.register(add2, u'com.myapp.add2')
print("registered 'com.myapp.add2' with id {}".format(reg.id))
# publish an event every second. The event payloads can be
# anything JSON- and msgpack- serializable
while True:
self.publish(u'com.myapp.hello', 'Hello, world!')
yield from asyncio.sleep(1)
await asyncio.sleep(1)
if __name__ == '__main__':

7
examples/asyncio/wamp/overview/frontend.py
View File

@ -4,16 +4,15 @@ from autobahn.asyncio.wamp import ApplicationSession, ApplicationRunner
class MyComponent(ApplicationSession):
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
# listening for the corresponding message from the "backend"
# (any session that .publish()es to this topic).
def onevent(msg):
print("Got event: {}".format(msg))
yield from self.subscribe(onevent, u'com.myapp.hello')
await self.subscribe(onevent, u'com.myapp.hello')
# call a remote procedure.
res = yield from self.call(u'com.myapp.add2', 2, 3)
res = await self.call(u'com.myapp.add2', 2, 3)
print("Got result: {}".format(res))

5
examples/asyncio/wamp/pubsub/basic/backend.py
View File

@ -39,14 +39,13 @@ class Component(ApplicationSession):
An application component that publishes an event every second.
"""
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
counter = 0
while True:
print("publish: com.myapp.topic1", counter)
self.publish(u'com.myapp.topic1', counter)
counter += 1
yield from asyncio.sleep(1)
await asyncio.sleep(1)
if __name__ == '__main__':

5
examples/asyncio/wamp/pubsub/basic/frontend.py
View File

@ -40,8 +40,7 @@ class Component(ApplicationSession):
stop after having received 5 events.
"""
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
self.received = 0
@ -51,7 +50,7 @@ class Component(ApplicationSession):
if self.received > 5:
self.leave()
yield from self.subscribe(on_event, u'com.myapp.topic1')
await self.subscribe(on_event, u'com.myapp.topic1')
def onDisconnect(self):
asyncio.get_event_loop().stop()

5
examples/asyncio/wamp/pubsub/complex/backend.py
View File

@ -43,8 +43,7 @@ class Component(ApplicationSession):
with complex payloads every second.
"""
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
counter = 0
while True:
print("publish: com.myapp.heartbeat")
@ -55,7 +54,7 @@ class Component(ApplicationSession):
self.publish(u'com.myapp.topic2', random.randint(0, 100), 23, c="Hello", d=obj)
counter += 1
yield from asyncio.sleep(1)
await asyncio.sleep(1)
if __name__ == '__main__':

7
examples/asyncio/wamp/pubsub/complex/frontend.py
View File

@ -43,19 +43,18 @@ class Component(ApplicationSession):
payload and of complex payload, and stops after 5 seconds.
"""
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
self.received = 0
def on_heartbeat(details=None):
print("Got heartbeat (publication ID {})".format(details.publication))
yield from self.subscribe(on_heartbeat, u'com.myapp.heartbeat', options=SubscribeOptions(details_arg='details'))
await self.subscribe(on_heartbeat, u'com.myapp.heartbeat', options=SubscribeOptions(details_arg='details'))
def on_topic2(a, b, c=None, d=None):
print("Got event: {} {} {} {}".format(a, b, c, d))
yield from self.subscribe(on_topic2, u'com.myapp.topic2')
await self.subscribe(on_topic2, u'com.myapp.topic2')
asyncio.get_event_loop().call_later(5, self.leave)
def onDisconnect(self):

5
examples/asyncio/wamp/pubsub/decorators/backend.py
View File

@ -40,8 +40,7 @@ class Component(ApplicationSession):
An application component that publishes an event every second.
"""
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
counter = 0
while True:
print("publish: com.myapp.topic1", counter)
@ -50,7 +49,7 @@ class Component(ApplicationSession):
print("publish: com.myapp.topic2 'Hello world.'")
self.publish(u'com.myapp.topic2', "Hello world.")
counter += 1
yield from asyncio.sleep(1)
await asyncio.sleep(1)
if __name__ == '__main__':

5
examples/asyncio/wamp/pubsub/decorators/frontend.py
View File

@ -42,13 +42,12 @@ class Component(ApplicationSession):
stop after having received 5 events.
"""
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
self.received = 0
# subscribe all methods on this object decorated with "@wamp.subscribe"
# as PubSub event handlers
results = yield from self.subscribe(self)
results = await self.subscribe(self)
for res in results:
if isinstance(res, wamp.protocol.Subscription):
# res is an Subscription instance

9
examples/asyncio/wamp/pubsub/options/backend.py
View File

@ -41,21 +41,20 @@ class Component(ApplicationSession):
An application component that publishes an event every second.
"""
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
def on_event(i):
print("Got event: {}".format(i))
yield from self.subscribe(on_event, u'com.myapp.topic1')
await self.subscribe(on_event, u'com.myapp.topic1')
counter = 0
while True:
publication = yield from self.publish(u'com.myapp.topic1',
publication = await self.publish(u'com.myapp.topic1',
counter,
options=PublishOptions(acknowledge=True, exclude_me=False))
print("Event published with publication ID {}".format(publication.id))
counter += 1
yield from asyncio.sleep(1)
await asyncio.sleep(1)
if __name__ == '__main__':

5
examples/asyncio/wamp/pubsub/options/frontend.py
View File

@ -42,8 +42,7 @@ class Component(ApplicationSession):
stop after having received 5 events.
"""
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
self.received = 0
def on_event(i, details=None):
@ -52,7 +51,7 @@ class Component(ApplicationSession):
if self.received > 5:
self.leave()
yield from self.subscribe(on_event, u'com.myapp.topic1',
await self.subscribe(on_event, u'com.myapp.topic1',
options=SubscribeOptions(details_arg='details'))
def onDisconnect(self):

5
examples/asyncio/wamp/pubsub/tls/backend_selfsigned.py
View File

@ -42,14 +42,13 @@ class Component(ApplicationSession):
An application component that publishes an event every second.
"""
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
counter = 0
while True:
print("publish: com.myapp.topic1", counter)
self.publish(u'com.myapp.topic1', counter)
counter += 1
yield from asyncio.sleep(1)
await asyncio.sleep(1)
if __name__ == '__main__':

5
examples/asyncio/wamp/pubsub/unsubscribe/backend.py
View File

@ -39,11 +39,10 @@ class Component(ApplicationSession):
An application component that publishes an event every second.
"""
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
counter = 0
while True:
self.publish(u'com.myapp.topic1', counter)
counter += 1
yield from asyncio.sleep(1)
await asyncio.sleep(1)

19
examples/asyncio/wamp/pubsub/unsubscribe/frontend.py
View File

@ -42,12 +42,10 @@ class Component(ApplicationSession):
resubscribes for another run. Then it stops.
"""
@asyncio.coroutine
def test(self):
async def test(self):
self.received = 0
@asyncio.coroutine
def on_event(i):
async def on_event(i):
print("Got event: {}".format(i))
self.received += 1
if self.received > 5:
@ -55,20 +53,19 @@ class Component(ApplicationSession):
if self.runs > 1:
self.leave()
else:
yield from self.subscription.unsubscribe()
await self.subscription.unsubscribe()
print("Unsubscribed .. continue in 5s ..")
# can't use loop.call_later() with a coroutine for some reason
yield from asyncio.sleep(5)
yield from self.test()
await asyncio.sleep(5)
await self.test()
self.subscription = yield from self.subscribe(on_event, u'com.myapp.topic1')
self.subscription = await self.subscribe(on_event, u'com.myapp.topic1')
print("Subscribed with subscription ID {}".format(self.subscription.id))
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
self.runs = 0
yield from self.test()
await self.test()
def onDisconnect(self):
asyncio.get_event_loop().stop()

7
examples/asyncio/wamp/rawsocket/backend.py
View File

@ -12,22 +12,21 @@ from runner import ApplicationRunnerRawSocket
class MyComponent(ApplicationSession):
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
# a remote procedure; see frontend.py for a Python front-end
# that calls this. Any language with WAMP bindings can now call
# this procedure if its connected to the same router and realm.
def add2(x, y):
log.debug('add2 called with %s %s', x, y)
return x + y
yield from self.register(add2, u'com.myapp.add2')
await self.register(add2, u'com.myapp.add2')
# publish an event every second. The event payloads can be
# anything JSON- and msgpack- serializable
while True:
self.publish(u'com.myapp.hello', 'Hello, world! Time is %s' % datetime.utcnow())
log.debug('Published msg')
yield from asyncio.sleep(1)
await asyncio.sleep(1)
if __name__ == '__main__':

9
examples/asyncio/wamp/rawsocket/frontend.py
View File

@ -12,25 +12,24 @@ from autobahn.wamp import ApplicationError
class MyComponent(ApplicationSession):
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
# listening for the corresponding message from the "backend"
# (any session that .publish()es to this topic).
def onevent(msg):
log.info("Got event: {}".format(msg))
yield from self.subscribe(onevent, u'com.myapp.hello')
await self.subscribe(onevent, u'com.myapp.hello')
# call a remote procedure.
count = 0
while True:
try:
res = yield from self.call(u'com.myapp.add2', count, count+1)
res = await self.call(u'com.myapp.add2', count, count+1)
log.info("Got result: {}".format(res))
except ApplicationError:
pass
count += 1
yield from asyncio.sleep(2)
await asyncio.sleep(2)
if __name__ == '__main__':

13
examples/asyncio/wamp/rpc/arguments/backend.py
View File

@ -40,8 +40,7 @@ class Component(ApplicationSession):
of arguments.
"""
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
def ping():
return
@ -59,11 +58,11 @@ class Component(ApplicationSession):
def arglen(*args, **kwargs):
return [len(args), len(kwargs)]
yield from self.register(ping, u'com.arguments.ping')
yield from self.register(add2, u'com.arguments.add2')
yield from self.register(stars, u'com.arguments.stars')
yield from self.register(orders, u'com.arguments.orders')
yield from self.register(arglen, u'com.arguments.arglen')
await self.register(ping, u'com.arguments.ping')
await self.register(add2, u'com.arguments.add2')
await self.register(stars, u'com.arguments.stars')
await self.register(orders, u'com.arguments.orders')
await self.register(arglen, u'com.arguments.arglen')
print("Registered methods; ready for frontend.")

27
examples/asyncio/wamp/rpc/arguments/frontend.py
View File

@ -39,43 +39,42 @@ class Component(ApplicationSession):
An application component calling the different backend procedures.
"""
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
yield from self.call(u'com.arguments.ping')
await self.call(u'com.arguments.ping')
print("Pinged!")
res = yield from self.call(u'com.arguments.add2', 2, 3)
res = await self.call(u'com.arguments.add2', 2, 3)
print("Add2: {}".format(res))
starred = yield from self.call(u'com.arguments.stars')
starred = await self.call(u'com.arguments.stars')
print("Starred 1: {}".format(starred))
starred = yield from self.call(u'com.arguments.stars', nick=u'Homer')
starred = await self.call(u'com.arguments.stars', nick=u'Homer')
print("Starred 2: {}".format(starred))
starred = yield from self.call(u'com.arguments.stars', stars=5)
starred = await self.call(u'com.arguments.stars', stars=5)
print("Starred 3: {}".format(starred))
starred = yield from self.call(u'com.arguments.stars', nick=u'Homer', stars=5)
starred = await self.call(u'com.arguments.stars', nick=u'Homer', stars=5)
print("Starred 4: {}".format(starred))
orders = yield from self.call(u'com.arguments.orders', u'coffee')
orders = await self.call(u'com.arguments.orders', u'coffee')
print("Orders 1: {}".format(orders))
orders = yield from self.call(u'com.arguments.orders', u'coffee', limit=10)
orders = await self.call(u'com.arguments.orders', u'coffee', limit=10)
print("Orders 2: {}".format(orders))
arglengths = yield from self.call(u'com.arguments.arglen')
arglengths = await self.call(u'com.arguments.arglen')
print("Arglen 1: {}".format(arglengths))
arglengths = yield from self.call(u'com.arguments.arglen', 1, 2, 3)
arglengths = await self.call(u'com.arguments.arglen', 1, 2, 3)
print("Arglen 1: {}".format(arglengths))
arglengths = yield from self.call(u'com.arguments.arglen', a=1, b=2, c=3)
arglengths = await self.call(u'com.arguments.arglen', a=1, b=2, c=3)
print("Arglen 2: {}".format(arglengths))
arglengths = yield from self.call(u'com.arguments.arglen', 1, 2, 3, a=1, b=2, c=3)
arglengths = await self.call(u'com.arguments.arglen', 1, 2, 3, a=1, b=2, c=3)
print("Arglen 3: {}".format(arglengths))
self.leave()

7
examples/asyncio/wamp/rpc/complex/backend.py
View File

@ -41,19 +41,18 @@ class Component(ApplicationSession):
return complex results.
"""
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
def add_complex(a, ai, b, bi):
return CallResult(c=a + b, ci=ai + bi)
yield from self.register(add_complex, u'com.myapp.add_complex')
await self.register(add_complex, u'com.myapp.add_complex')
def split_name(fullname):
forename, surname = fullname.split()
return CallResult(forename, surname)
yield from self.register(split_name, u'com.myapp.split_name')
await self.register(split_name, u'com.myapp.split_name')
if __name__ == '__main__':

7
examples/asyncio/wamp/rpc/complex/frontend.py
View File

@ -41,13 +41,12 @@ class Component(ApplicationSession):
produce complex results and showing how to access those.
"""
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
res = yield from self.call(u'com.myapp.add_complex', 2, 3, 4, 5)
res = await self.call(u'com.myapp.add_complex', 2, 3, 4, 5)
print("Result: {} + {}i".format(res.kwresults['c'], res.kwresults['ci']))
res = yield from self.call(u'com.myapp.split_name', 'Homer Simpson')
res = await self.call(u'com.myapp.split_name', 'Homer Simpson')
print("Forname: {}, Surname: {}".format(res.results[0], res.results[1]))
self.leave()

5
examples/asyncio/wamp/rpc/decorators/backend.py
View File

@ -42,13 +42,12 @@ class Component(ApplicationSession):
An application component registering RPC endpoints using decorators.
"""
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
# register all methods on this object decorated with "@wamp.register"
# as a RPC endpoint
##
results = yield from self.register(self)
results = await self.register(self)
for res in results:
if isinstance(res, wamp.protocol.Registration):
# res is an Registration instance

5
examples/asyncio/wamp/rpc/decorators/frontend.py
View File

@ -39,8 +39,7 @@ class Component(ApplicationSession):
An application component calling the different backend procedures.
"""
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
procs = [u'com.mathservice.add2',
u'com.mathservice.mul2',
@ -48,7 +47,7 @@ class Component(ApplicationSession):
try:
for proc in procs:
res = yield from self.call(proc, 2, 3)
res = await self.call(proc, 2, 3)
print("{}: {}".format(proc, res))
except Exception as e:
print("Something went wrong: {}".format(e))

9
examples/asyncio/wamp/rpc/errors/backend.py
View File

@ -51,8 +51,7 @@ class Component(ApplicationSession):
Example WAMP application backend that raised exceptions.
"""
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
# raising standard exceptions
##
@ -63,7 +62,7 @@ class Component(ApplicationSession):
# this also will raise, if x < 0
return math.sqrt(x)
yield from self.register(sqrt, u'com.myapp.sqrt')
await self.register(sqrt, u'com.myapp.sqrt')
# raising WAMP application exceptions
##
@ -79,7 +78,7 @@ class Component(ApplicationSession):
# forward keyword arguments in exceptions
raise ApplicationError(u"com.myapp.error.invalid_length", min=3, max=10)
yield from self.register(checkname, u'com.myapp.checkname')
await self.register(checkname, u'com.myapp.checkname')
# defining and automapping WAMP application exceptions
##
@ -89,7 +88,7 @@ class Component(ApplicationSession):
if a < b:
raise AppError1(b - a)
yield from self.register(compare, u'com.myapp.compare')
await self.register(compare, u'com.myapp.compare')
if __name__ == '__main__':

11
examples/asyncio/wamp/rpc/errors/frontend.py
View File

@ -51,14 +51,13 @@ class Component(ApplicationSession):
Example WAMP application frontend that catches exceptions.
"""
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
# catching standard exceptions
##
for x in [2, 0, -2]:
try:
res = yield from self.call(u'com.myapp.sqrt', x)
res = await self.call(u'com.myapp.sqrt', x)
except Exception as e:
print("Error: {} {}".format(e, e.args))
else:
@ -68,7 +67,7 @@ class Component(ApplicationSession):
##
for name in ['foo', 'a', '*' * 11, 'Hello']:
try:
res = yield from self.call(u'com.myapp.checkname', name)
res = await self.call(u'com.myapp.checkname', name)
except ApplicationError as e:
print("Error: {} {} {} {}".format(e, e.error, e.args, e.kwargs))
else:
@ -79,11 +78,11 @@ class Component(ApplicationSession):
self.define(AppError1)
try:
yield from self.call(u'com.myapp.compare', 3, 17)
await self.call(u'com.myapp.compare', 3, 17)
except AppError1 as e:
print("Compare Error: {}".format(e))
yield from self.leave()
await self.leave()
def onDisconnect(self):
asyncio.get_event_loop().stop()

5
examples/asyncio/wamp/rpc/options/backend.py
View File

@ -41,8 +41,7 @@ class Component(ApplicationSession):
different kinds of arguments.
"""
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
def square(val, details=None):
print("square called from: {}".format(details.caller))
@ -57,7 +56,7 @@ class Component(ApplicationSession):
self.publish(u'com.myapp.square_on_nonpositive', val, options=options)
return val * val
yield from self.register(square, u'com.myapp.square', RegisterOptions(details_arg='details'))
await self.register(square, u'com.myapp.square', RegisterOptions(details_arg='details'))
if __name__ == '__main__':

9
examples/asyncio/wamp/rpc/options/frontend.py
View File

@ -40,19 +40,18 @@ class Component(ApplicationSession):
An application component calling the different backend procedures.
"""
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
def on_event(val):
print("Someone requested to square non-positive: {}".format(val))
yield from self.subscribe(on_event, u'com.myapp.square_on_nonpositive')
await self.subscribe(on_event, u'com.myapp.square_on_nonpositive')
for val in [2, 0, -2]:
res = yield from self.call(u'com.myapp.square', val, options=CallOptions())
res = await self.call(u'com.myapp.square', val, options=CallOptions())
print("Squared {} = {}".format(val, res))
yield from self.leave()
await self.leave()
def onDisconnect(self):
asyncio.get_event_loop().stop()

12
examples/asyncio/wamp/rpc/progress/backend.py
View File

@ -40,20 +40,18 @@ class Component(ApplicationSession):
Application component that produces progressive results.
"""
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
@asyncio.coroutine
def longop(n, details=None):
async def longop(n, details=None):
if details.progress:
for i in range(n):
details.progress(i)
yield from asyncio.sleep(1)
await asyncio.sleep(1)
else:
yield from asyncio.sleep(1 * n)
await asyncio.sleep(1 * n)
return n
yield from self.register(longop, u'com.myapp.longop', RegisterOptions(details_arg='details'))
await self.register(longop, u'com.myapp.longop', RegisterOptions(details_arg='details'))
if __name__ == '__main__':

5
examples/asyncio/wamp/rpc/progress/frontend.py
View File

@ -40,13 +40,12 @@ class Component(ApplicationSession):
Application component that consumes progressive results.
"""
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
def on_progress(i):
print("Progress: {}".format(i))
res = yield from self.call(u'com.myapp.longop', 3, options=CallOptions(on_progress=on_progress))
res = await self.call(u'com.myapp.longop', 3, options=CallOptions(on_progress=on_progress))
print("Final: {}".format(res))

12
examples/asyncio/wamp/rpc/slowsquare/backend.py
View File

@ -39,20 +39,18 @@ class Component(ApplicationSession):
A math service application component.
"""
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
def square(x):
return x * x
yield from self.register(square, u'com.math.square')
await self.register(square, u'com.math.square')
@asyncio.coroutine
def slowsquare(x, delay=1):
yield from asyncio.sleep(delay)
async def slowsquare(x, delay=1):
await asyncio.sleep(delay)
return x * x
yield from self.register(slowsquare, u'com.math.slowsquare')
await self.register(slowsquare, u'com.math.slowsquare')
print("Registered com.math.slowsquare")

5
examples/asyncio/wamp/rpc/slowsquare/frontend.py
View File

@ -43,8 +43,7 @@ class Component(ApplicationSession):
An application component using the time service.
"""
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
def got(started, msg, f):
res = f.result()
@ -59,7 +58,7 @@ class Component(ApplicationSession):
d2 = self.call(u'com.math.square', 3)
d2.add_done_callback(partial(got, t2, "Quick Square"))
yield from asyncio.gather(d1, d2)
await asyncio.gather(d1, d2)
print("All finished.")
self.leave()

5
examples/asyncio/wamp/rpc/timeservice/backend.py
View File

@ -41,14 +41,13 @@ class Component(ApplicationSession):
A simple time service application component.
"""
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
def utcnow():
now = datetime.datetime.utcnow()
return now.strftime("%Y-%m-%dT%H:%M:%SZ")
yield from self.register(utcnow, u'com.timeservice.now')
await self.register(utcnow, u'com.timeservice.now')
if __name__ == '__main__':

5
examples/asyncio/wamp/rpc/timeservice/frontend.py
View File

@ -41,10 +41,9 @@ class Component(ApplicationSession):
An application component using the time service.
"""
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
try:
now = yield from self.call(u'com.timeservice.now')
now = await self.call(u'com.timeservice.now')
except Exception as e:
print("Error: {}".format(e))
else:

5
examples/asyncio/wamp/session/series/frontend.py
View File

@ -47,12 +47,11 @@ class Component(ApplicationSession):
ApplicationSession.__init__(self, config)
self.count = 0
@asyncio.coroutine
def onJoin(self, details):
async def onJoin(self, details):
print("Realm joined (WAMP session started).")
try:
now = yield from self.call(u'com.timeservice.now')
now = await self.call(u'com.timeservice.now')
except Exception as e:
print("Error: {}".format(e))
else:

5
examples/asyncio/websocket/echo/client_coroutines.py
View File

@ -38,15 +38,14 @@ class MyClientProtocol(WebSocketClientProtocol):
def onConnect(self, response):
print("Server connected: {0}".format(response.peer))
@asyncio.coroutine
def onOpen(self):
async def onOpen(self):
print("WebSocket connection open.")
# start sending messages every second ..
while True:
self.sendMessage(u"Hello, world!".encode('utf8'))
self.sendMessage(b"\x00\x01\x03\x04", isBinary=True)
yield from asyncio.sleep(1)
await asyncio.sleep(1)
def onMessage(self, payload, isBinary):
if isBinary:

16
examples/asyncio/websocket/slowsquare/server.py
View File

@ -26,30 +26,24 @@
from autobahn.asyncio.websocket import WebSocketServerProtocol, \
WebSocketServerFactory
try:
import asyncio
except ImportError:
import trollius as asyncio
import asyncio
import json
class SlowSquareServerProtocol(WebSocketServerProtocol):
@asyncio.coroutine
def slowsquare(self, x):
async def slowsquare(self, x):
if x > 5:
raise Exception("number too large")
else:
yield from asyncio.sleep(1)
await asyncio.sleep(1)
return x * x
@asyncio.coroutine
def onMessage(self, payload, isBinary):
async def onMessage(self, payload, isBinary):
if not isBinary:
x = json.loads(payload.decode('utf8'))
try:
res = yield from self.slowsquare(x)
res = await self.slowsquare(x)
except Exception as e:
self.sendClose(1000, "Exception raised: {0}".format(e))
else: