gruberb/protohackers
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Change server address, make write to buf async

Browse source
This commit is contained in:
Bastian Gruber 2023-04-24 22:57:57 +02:00
parent a245bc8200
commit 7795854613
No known key found for this signature in database
GPG key ID: BE9F8C772B188CBF
2 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
problem_02/bin/server.rs
View file

@ -7,7 +7,7 @@ use tokio::signal;
pub async fn main() -> problem_02::Result<()> { pub async fn main() -> problem_02::Result<()> {
tracing_subscriber::fmt::try_init()?; tracing_subscriber::fmt::try_init()?;
let listener = TcpListener::bind(&format!("127.0.0.1:{}", DEFAULT_PORT)).await?; let listener = TcpListener::bind(&format!("0.0.0.0:{}", DEFAULT_PORT)).await?;
server::run(listener, signal::ctrl_c()).await?; server::run(listener, signal::ctrl_c()).await?;

2
problem_02/src/connection.rs
View file

@ -64,7 +64,7 @@ impl Connection {
pub async fn write_frame(&mut self, frame: &Frame) -> crate::Result<()> { pub async fn write_frame(&mut self, frame: &Frame) -> crate::Result<()> {
debug!(?frame); debug!(?frame);
if let Frame::Response(mean) = frame { if let Frame::Response(mean) = frame {
let _ = self.stream.write(&[mean.to_ne_bytes()[0]]); let _ = self.stream.write(&[mean.to_ne_bytes()[0]]).await?;
return Ok(()); return Ok(());
} }