312 class async_activity : utils::NoAssign {  class
326         ServiceThreadBody( async_activity* activity ) : my_activity( activity ) {}  in ServiceThreadBody()
329         async_activity* my_activity;
332     async_activity(int expected_items, bool deferred = false, int sleep_time = 50)  in async_activity()  function in async_activity
342     async_activity( const async_activity& )  in async_activity()  argument
349     ~async_activity() {  in ~async_activity()
415         async_activity<input_type, output_type> my_async_activity(async_expected_items);  in run()
534         async_activity<input_type, output_type> my_async_activity(async_expected_items, false, 0);  in run()
611     typedef async_activity<input_type, output_type> async_activity_type;
722     AsyncActivity<node_t> async_activity(3);  in test_follows()  local
733         async_activity.submit(input, &gtw);  in test_follows()
744     async_activity.wait_for_all();  in test_follows()
760     AsyncActivity<node_t> async_activity(1);  in test_precedes()  local
767         async_activity.submit(input, &gtw);  in test_precedes()
775     async_activity.wait_for_all();  in test_precedes()