pypushflow.tests.test_threadcounteractor.MyThreadCountingActor#

class pypushflow.tests.test_threadcounteractor.MyThreadCountingActor(thread_counter, downstream_actors=())[source]#

Bases: ThreadCountingActor

property pool_resources#
trigger(state)[source]#