aboutsummaryrefslogtreecommitdiff
path: root/examples/std/src/bin/tcp_accept.rs
diff options
context:
space:
mode:
Diffstat (limited to 'examples/std/src/bin/tcp_accept.rs')
-rw-r--r--examples/std/src/bin/tcp_accept.rs17
1 files changed, 2 insertions, 15 deletions
diff --git a/examples/std/src/bin/tcp_accept.rs b/examples/std/src/bin/tcp_accept.rs
index 5d36b739d..18646a083 100644
--- a/examples/std/src/bin/tcp_accept.rs
+++ b/examples/std/src/bin/tcp_accept.rs
@@ -1,5 +1,3 @@
1use core::fmt::Write as _;
2
3use clap::Parser; 1use clap::Parser;
4use embassy_executor::{Executor, Spawner}; 2use embassy_executor::{Executor, Spawner};
5use embassy_net::tcp::TcpSocket; 3use embassy_net::tcp::TcpSocket;
@@ -28,16 +26,6 @@ async fn net_task(mut runner: embassy_net::Runner<'static, TunTapDevice>) -> ! {
28 runner.run().await 26 runner.run().await
29} 27}
30 28
31#[derive(Default)]
32struct StrWrite(pub heapless::Vec<u8, 30>);
33
34impl core::fmt::Write for StrWrite {
35 fn write_str(&mut self, s: &str) -> Result<(), core::fmt::Error> {
36 self.0.extend_from_slice(s.as_bytes()).unwrap();
37 Ok(())
38 }
39}
40
41#[embassy_executor::task] 29#[embassy_executor::task]
42async fn main_task(spawner: Spawner) { 30async fn main_task(spawner: Spawner) {
43 let opts: Opts = Opts::parse(); 31 let opts: Opts = Opts::parse();
@@ -85,9 +73,8 @@ async fn main_task(spawner: Spawner) {
85 73
86 // Write some quick output 74 // Write some quick output
87 for i in 1..=5 { 75 for i in 1..=5 {
88 let mut w = StrWrite::default(); 76 let s = format!("{}! ", i);
89 write!(w, "{}! ", i).unwrap(); 77 let r = socket.write_all(s.as_bytes()).await;
90 let r = socket.write_all(&w.0).await;
91 if let Err(e) = r { 78 if let Err(e) = r {
92 warn!("write error: {:?}", e); 79 warn!("write error: {:?}", e);
93 return; 80 return;