pypushflow.tests.test_threadcounteractor.MyThreadCountingActor

class pypushflow.tests.test_threadcounteractor.MyThreadCountingActor(thread_counter, downstream_actors=())

Bases: ThreadCountingActor

property pool_resources

trigger(state)