make doc consistent

README.rst

@@ -53,7 +53,7 @@ Here's an example processing a stream of incoming orders:
         amount: int
 
     @app.agent(value_type=Order)
-    async def order(orders):
+    async def process_order(orders):
         async for order in orders:
             # process infinite stream of orders.
             print(f'Order for {order.account_id}: {order.amount}')

docs/includes/intro.txt

@@ -29,7 +29,7 @@ Here's an example processing a stream of incoming orders:
         amount: int
 
     @app.agent(value_type=Order)
-    async def order(orders):
+    async def process_order(orders):
         async for order in orders:
             # process infinite stream of orders.
             print(f'Order for {order.account_id}: {order.amount}')

docs/userguide/streams.rst

@@ -310,7 +310,7 @@ stream by taking a "key type" as argument:
     orders_topic = app.topic('orders', value_type=Order)
 
     @app.agent(orders_topic)
-    async def process(orders):
+    async def process_order(orders):
         async for order in orders.group_by(Order.account_id):
             ...
 
@@ -338,7 +338,7 @@ the data in streams you can manually extract the key used for repartitioning:
         return json.loads(order)['account_id']
 
     @app.agent(app.topic('order'))
-    async def process(orders):
+    async def process_order(orders):
         async for order in orders.group_by(get_order_account_id):
             ...
 

docs/userguide/testing.rst

@@ -33,7 +33,7 @@ To test an agent when unit testing or functional testing, use the special
     orders_for_account = app.Table('order-count-by-account', default=int)
 
     @app.agent(orders_topic)
-    async def order(orders):
+    async def process_order(orders):
         async for order in orders.group_by(Order.account_id):
             orders_for_account[order.account_id] += 1
             yield order