From 0ee7d3be4d5b2048d92f7cea86b1e2702ff9e78c Mon Sep 17 00:00:00 2001
From: Herbert Reiter <46045854+damoasda@users.noreply.github.com>
Date: Sat, 30 Sep 2023 09:40:55 +0200
Subject: [PATCH] =?UTF-8?q?Text=C3=A4nderungen=20aus=20dem=20Originaltext?=
 =?UTF-8?q?=20=C3=BCbernehmen?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/ch20-01-single-threaded.md | 19 +++++++++++--------
 src/ch20-02-multithreaded.md   | 12 ++++++------
 2 files changed, 17 insertions(+), 14 deletions(-)

diff --git a/src/ch20-01-single-threaded.md b/src/ch20-01-single-threaded.md
index c39a58d..277cab1 100644
--- a/src/ch20-01-single-threaded.md
+++ b/src/ch20-01-single-threaded.md
@@ -336,9 +336,10 @@ Code in Codeblock 20-3.
 <span class="filename">Dateiname: src/main.rs</span>
 
 ```rust,no_run
-# use std::io::prelude::*;
-# use std::net::TcpListener;
-# use std::net::TcpStream;
+# use std::{
+#     io::{prelude::*, BufReader},
+#     net::{TcpListener, TcpStream},
+# };
 #
 # fn main() {
 #     let listener = TcpListener::bind("127.0.0.1:7878").unwrap();
@@ -351,14 +352,16 @@ Code in Codeblock 20-3.
 # }
 #
 fn handle_connection(mut stream: TcpStream) {
-    let mut buffer = [0; 1024];
-
-    stream.read(&mut buffer).unwrap();
+    let buf_reader = BufReader::new(&mut stream);
+    let http_request: Vec<_> = buf_reader
+        .lines()
+        .map(|result| result.unwrap())
+        .take_while(|line| !line.is_empty())
+        .collect();
 
     let response = "HTTP/1.1 200 OK\r\n\r\n";
 
-    stream.write(response.as_bytes()).unwrap();
-    stream.flush().unwrap();
+    stream.write_all(response.as_bytes()).unwrap();
 }
 ```
 
diff --git a/src/ch20-02-multithreaded.md b/src/ch20-02-multithreaded.md
index 89f73ff..7443b2f 100644
--- a/src/ch20-02-multithreaded.md
+++ b/src/ch20-02-multithreaded.md
@@ -484,7 +484,7 @@ annimmt:
 
 <span class="filename">Dateiname: src/lib.rs</span>
 
-```rust
+```rust,noplayground
 # pub struct ThreadPool;
 #
 impl ThreadPool {
@@ -608,7 +608,7 @@ pub fn spawn<F, T>(f: F) -> JoinHandle<T>
     where
         F: FnOnce() -> T,
         F: Send + 'static,
-        T: Send + 'static
+        T: Send + 'static,
 ```
 
 Die Funktion `spawn` gibt einen `JoinHandle<T>` zurück, wobei `T` der Typ ist,
@@ -990,12 +990,12 @@ Wenn wir versuchen, diesen Code zu überprüfen, erhalten wir diesen Fehler:
 $ cargo check
     Checking hello v0.1.0 (file:///projects/hello)
 error[E0382]: use of moved value: `receiver`
-  --> src/lib.rs:27:42
+  --> src/lib.rs:26:42
    |
-22 |         let (sender, receiver) = mpsc::channel();
+21 |         let (sender, receiver) = mpsc::channel();
    |                      -------- move occurs because `receiver` has type `std::sync::mpsc::Receiver<Job>`, which does not implement the `Copy` trait
 ...
-27 |             workers.push(Worker::new(id, receiver));
+26 |             workers.push(Worker::new(id, receiver));
    |                                          ^^^^^^^^ value moved here, in previous iteration of loop
 
 For more information about this error, try `rustc --explain E0382`.
@@ -1155,7 +1155,7 @@ impl ThreadPool {
 #
 #         ThreadPool { workers, sender }
 #     }
-#
+
     pub fn execute<F>(&self, f: F)
     where
         F: FnOnce() + Send + 'static,