forked from goodboy/tractor
1
0
Fork 0

Document per-func actors for clarity

init_docs
Tyler Goodlet 2018-07-12 16:20:38 -04:00
parent 049513235d
commit 232de86143
2 changed files with 6 additions and 0 deletions

View File

@ -267,12 +267,14 @@ actor and print the results to your screen:
import tractor
# this is the first 2 actors, streamer_1 and streamer_2
async def stream_data(seed):
for i in range(seed):
yield i
await trio.sleep(0) # trigger scheduler
# this is the third actor; the aggregator
async def aggregate(seed):
"""Ensure that the two streams we receive match but only stream
a single set of values to the parent.
@ -325,6 +327,7 @@ actor and print the results to your screen:
print("AGGREGATOR COMPLETE!")
# this is the main actor and *arbiter*
async def main():
# a nursery which spawns "actors"
async with tractor.open_nursery() as nursery:

View File

@ -352,12 +352,14 @@ def test_cancel_single_subactor():
tractor.run(main, arbiter_addr=_arb_addr)
# this is the first 2 actors, streamer_1 and streamer_2
async def stream_data(seed):
for i in range(seed):
yield i
await trio.sleep(0) # trigger scheduler
# this is the third actor; the aggregator
async def aggregate(seed):
"""Ensure that the two streams we receive match but only stream
a single set of values to the parent.
@ -409,6 +411,7 @@ async def aggregate(seed):
print("AGGREGATOR COMPLETE!")
# this is the main actor and *arbiter*
async def a_quadruple_example():
# a nursery which spawns "actors"
async with tractor.open_nursery() as nursery: