pub fn new(
        test_case_name: String,
        listener: CaseListenerRequestStream,
        logger_socket: zx::Socket,
        sender: mpsc::Sender<TestEvent>,
    ) -> Self {
        let log_fut =
            Self::collect_and_send_logs(test_case_name.clone(), logger_socket, sender.clone());
        let f = Self::process_run_event(test_case_name, listener, log_fut, sender);

        let (remote, remote_handle) = f.remote_handle();
        fasync::spawn(remote);

        TestCaseProcessor { f: Some(remote_handle.boxed()) }
    }
/// This will start processing of logs and events in the background. The owner of this object
/// should call `wait_for_finish` method  to make sure all the background task completed.
This will start processing of logs and events in the background. The owner of this object
should call `wait_for_finish` method  to make sure all the background task completed.
This will start processing of logs and events in the background . The owner of this object should call ` wait_for_finish ` method to make sure all the background task completed .
pub fn new(
        test_case_name: String,
        listener: CaseListenerRequestStream,
        logger_socket: zx::Socket,
        sender: mpsc::Sender<TestEvent>,
    ) -> Self {
        let log_fut =
            Self::collect_and_send_logs(test_case_name.clone(), logger_socket, sender.clone());
        let f = Self::process_run_event(test_case_name, listener, log_fut, sender);
        let (remote, remote_handle) = f.remote_handle();
        fasync::spawn(remote);
        TestCaseProcessor { f: Some(remote_handle.boxed()) }
    }
pub fn new ( test_case_name : String , listener : CaseListenerRequestStream , logger_socket : zx :: Socket , sender : mpsc :: Sender < TestEvent > , ) -> Self { let log_fut = Self :: collect_and_send_logs ( test_case_name . clone ( ) , logger_socket , sender . clone ( ) ) ; let f = Self :: process_run_event ( test_case_name , listener , log_fut , sender ) ; let ( remote , remote_handle ) = f . remote_handle ( ) ; fasync :: spawn ( remote ) ; TestCaseProcessor { f : Some ( remote_handle . boxed ( ) ) } }
This will start processing of logs and events in the background.
This will start processing of logs and events in the background .
test_case_name
String
listener
CaseListenerRequestStream
logger_socket
zx::Socket
sender
mpsc::Sender<TestEvent>
test_case_name
String
listener
CaseListenerRequestStream
logger_socket
zx::Socket
sender
mpsc::Sender<TestEvent>