fn accept()

in src/flowgger/input/tls/tls_input.rs [32:50]

• 19 lines of code
• 4 McCabe index (conditional complexity)

    fn accept(
        &self,
        tx: SyncSender<Vec<u8>>,
        decoder: Box<dyn Decoder + Send>,
        encoder: Box<dyn Encoder + Send>,
    ) {
        let listener = TcpListener::bind(&self.listen as &str).unwrap();
        for client in listener.incoming() {
            if let Ok(client) = client {
                let _ = client.set_read_timeout(self.timeout);
                let tx = tx.clone();
                let (decoder, encoder) = (decoder.clone_boxed(), encoder.clone_boxed());
                let tls_config = self.tls_config.clone();
                thread::spawn(move || {
                    handle_client(client, tx, decoder, encoder, tls_config);
                });
            }
        }
    }