pub struct FlutR { stream: TcpStream, msgs: PixelMsgs, } impl FlutR { fn new(host: Host, port: u16, msgs: PixelMsgs) -> Result { let stream = TcpStream::connect(format!("{host}:{port}"))?; Ok(FlutR { stream, msgs }) } fn flut(&mut self) { for msg in self.msgs.clone() { dbg!(&msg); let result = self.stream.write(msg.as_str().as_bytes()); match result { Ok(_) => (), Err(err) => eprintln!("{err}"), } let _ = self.stream.flush(); } } }