Lines Matching refs:a
11 let mut a = Agent::new(Some(Arc::new(handler_tx))); in test_agent_process_in_transaction() localVariable
13 a.start(m.transaction_id, Instant::now())?; in test_agent_process_in_transaction()
14 a.process(m)?; in test_agent_process_in_transaction()
15 a.close()?; in test_agent_process_in_transaction()
37 let mut a = Agent::new(Some(Arc::new(handler_tx))); in test_agent_process() localVariable
39 a.process(m.clone())?; in test_agent_process()
40 a.close()?; in test_agent_process()
55 let result = a.process(m); in test_agent_process()
73 let mut a = Agent::new(noop_handler()); in test_agent_start() localVariable
76 a.start(id, deadline)?; in test_agent_start()
78 let result = a.start(id, deadline); in test_agent_start()
90 a.close()?; in test_agent_start()
93 let result = a.start(id, deadline); in test_agent_start()
106 let result = a.set_handler(noop_handler()); in test_agent_start()
125 let mut a = Agent::new(Some(Arc::new(handler_tx))); in test_agent_stop() localVariable
127 let result = a.stop(TransactionId::default()); in test_agent_stop()
142 a.start(id, deadline)?; in test_agent_stop()
143 a.stop(id)?; in test_agent_stop()
165 a.close()?; in test_agent_stop()
167 let result = a.close(); in test_agent_stop()
180 let result = a.stop(TransactionId::default()); in test_agent_stop()