How to use the appier.coroutine function in appier
To help you get started, we’ve selected a few appier examples, based on popular ways it is used in public projects.
Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
hivesolutions / appier / examples / async / async_old.py View on Github 
@appier.coroutine
def handler(self):
message = "hello world\n"
for value in appier.sleep(3.0): yield value
message += "timeout: %.2f\n" % 3.0
future = appier.build_future()
for value in self.calculator(future, 2, 2): yield value
message += "result: %d\n" % future.result()
yield message @appier.coroutine
def handler_partial(self):
yield "hello world\n"
timeout = yield from appier.sleep(3.0)
yield "timeout: %.2f\n" % timeout
result = yield from self.calculator(2, 2)
yield "result: %d\n" % result @appier.coroutine
def handler_partial(self):
yield "hello world\n"
for value in appier.sleep(3.0): yield value
yield "timeout: %.2f\n" % 3.0
result = appier.build_future()
for value in self.calculator(result, 2, 2): yield value
yield "result: %d\n" % result.result() @appier.coroutine
def read_file(self, file_path, chunk = 65536, delay = 0.0):
count = 0
file = open(file_path, "rb")
try:
while True:
data = file.read(chunk)
if not data: break
count += len(data)
if delay:
for value in appier.sleep(delay): yield value
yield data
finally:
file.close() @appier.coroutine
def calculator(self, *args, **kwargs):
print("computing...")
yield from appier.sleep(3.0)
print("finished computing...")
return sum(args) @appier.coroutine
def handler(self):
message = "hello world\n"
timeout = yield from appier.sleep(3.0)
message += "timeout: %.2f\n" % timeout
result = yield from self.calculator(2, 2)
message += "result: %d\n" % result
yield message @appier.coroutine
def read_file(self, file_path, chunk = 65536, delay = 0.0):
count = 0
file = open(file_path, "rb")
try:
while True:
data = file.read(chunk)
if not data: break
count += len(data)
if delay: yield from appier.sleep(delay)
yield data
finally:
file.close()
return count @appier.coroutine
def calculator(self, future, *args, **kwargs):
print("computing...")
for value in appier.sleep(3.0): yield value
print("finished computing...")
future.set_result(sum(args))
