clippy fixes

Author: cowlicks

src/framing.rs

@@ -16,7 +16,7 @@ use crate::util::{stat_uint24_le, wrap_uint24_le};
 const BUF_SIZE: usize = 1024 * 64;
 const _HEADER_LEN: usize = 3;
 
-/// Turn a `AsyncWrite` of length prefixed messages and emit the messages with a Stream
+/// take a `AsyncWrite` of length prefixed messages and emit them as a Stream
 pub struct Uint24LELengthPrefixedFraming<IO> {
     io: IO,
     /// Data from [`Self::io`]'s [`AsyncRead`] interface to be sent out via the [`Stream`] interface.

src/test_utils.rs

@@ -188,6 +188,7 @@ fn result_channel() -> (Sender<Vec<u8>>, impl Stream<Item = io::Result<Vec<u8>>>
     (tx, rx.map(Ok))
 }
 
+#[allow(clippy::type_complexity)]
 pub(crate) fn create_result_connected() -> (
     Moo<impl Stream<Item = io::Result<Vec<u8>>>, impl Sink<Vec<u8>>>,
     Moo<impl Stream<Item = io::Result<Vec<u8>>>, impl Sink<Vec<u8>>>,

tests/js_interop.rs

@@ -767,7 +767,10 @@ async fn on_replication_message(
                     for i in 0..new_info.contiguous_length {
                         let value = String::from_utf8(hypercore.get(i).await?.unwrap()).unwrap();
                         let line = format!("{} {}\n", i, value);
-                        writer.write(line.as_bytes()).await?;
+                        let n_written = writer.write(line.as_bytes()).await?;
+                        if line.len() != n_written {
+                            panic!("Couldn't write all write all bytse");
+                        }
                     }
                     writer.flush().await?;
                     true