use std::io::Read;

use flate2::read::GzDecoder;

use prost::Message;

use proto::Request;
use proto::request::Msg::{GetCount, PostWords};

    let mut buf = [0; 1];

    let mut int_buf = [0u8; 4];

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

        let req: Request = Message::decode(&buf[..]).unwrap();
        if let Some(msg) = req.msg {
            match msg {
                GetCount(_) => {}
                PostWords(words) => {
                    let mut s = String::new();
                    GzDecoder::new(&words.data[..]).read_to_string(&mut s).unwrap();
                    for w in s.split(char::is_whitespace) {
                        if w.len() == 0 { continue; }
                        dbg!(w);
                    }
                }
            }
        }

flate2 = "1.0"

name = "crc32fast"
version = "1.3.2"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "b540bd8bc810d3885c6ea91e2018302f68baba2129ab3e88f32389ee9370880d"
dependencies = [
 "cfg-if",
]
[[package]]

[[package]]
name = "flate2"
version = "1.0.23"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "b39522e96686d38f4bc984b9198e3a0613264abaebaff2c5c918bfa6b6da09af"
dependencies = [
 "cfg-if",
 "crc32fast",
 "libc",
 "miniz_oxide",
]

 "flate2",