async fn handle(stream: TcpStream, dict: &DashSet<String, FxBuildHasher>) {
    let mut stream = stream;
    let mut int_buf = [0u8; 4];

fn handle(mut stream: TcpStream, dict: &DashSet<String, FxBuildHasher>) {

    let mut buf = Vec::new();
    let mut s = String::new();

        if stream.read(&mut int_buf).is_err() { return; };
        let size = u32::from_be_bytes(int_buf) as usize;
        let mut buf = vec![0u8; size];
        if stream.read(&mut buf).is_err() { return; };

        buf.resize(4, 0);
        if stream.read_exact(&mut buf).is_err() { return; };
        let size = u32::from_be_bytes(buf[..4].try_into().unwrap()) as usize;
        buf.resize(size, 0);
        if stream.read_exact(&mut buf).is_err() { return; };

                    let mut s = String::new();

                    s.clear();

    let mut threads = Vec::new();

        std::thread::spawn(move || handle(stream.unwrap(), dict_ref));

        let stream = stream.unwrap();
        threads.push(std::thread::spawn(move || handle(stream, dict_ref)));

    for thread in threads {
        thread.join();
    }