Update crossbeam version

Cargo.toml

@@ -4,7 +4,7 @@ version = "0.1.0"
 authors = ["markschl <[email protected]>"]
 
 [dependencies]
-crossbeam = "0.4"
+crossbeam = "0.6"
 
 [profile.bench]
 lto = true

src/read.rs

@@ -182,7 +182,7 @@ where
     }
 
     crossbeam::scope(|scope| {
-        let handle = scope.spawn(move || {
+        let handle = scope.spawn(move |_| {
             let mut reader = init_reader()?;
             while let Ok(Some(mut buffer)) = empty_recv.recv() {
                 if let Err(e) = buffer.refill(&mut reader) {
@@ -213,5 +213,5 @@ where
         reader.get_errors()?;
 
         Ok(out)
-    })
+    }).unwrap()
 }

src/write.rs

@@ -214,7 +214,7 @@ where
     }
 
     crossbeam::scope(|scope| {
-        let handle = scope.spawn::<_, Result<_, E>>(move || {
+        let handle = scope.spawn::<_, Result<_, E>>(move |_| {
             let mut writer = init_writer()?;
 
             while let Ok(msg) = full_recv.recv() {
@@ -257,5 +257,5 @@ where
         writer.get_errors()?;
 
         Ok((out, of.unwrap()))
-    })
+    }).unwrap()
 }