aboutsummaryrefslogtreecommitdiffstats
path: root/src/writer.rs
diff options
context:
space:
mode:
authorLibravatar cel 🌸 <cel@bunny.garden>2024-12-06 06:33:10 +0000
committerLibravatar cel 🌸 <cel@bunny.garden>2024-12-06 06:33:10 +0000
commit4f0691de7d8d00e6c58da58186e511425f7470ed (patch)
tree7ef46d1fa3f588f16d1b68624d47e9f9deea9af5 /src/writer.rs
parent1d831b4c4e730a7a7a4556e6c71aecc88d73d9ee (diff)
downloadpeanuts-4f0691de7d8d00e6c58da58186e511425f7470ed.tar.gz
peanuts-4f0691de7d8d00e6c58da58186e511425f7470ed.tar.bz2
peanuts-4f0691de7d8d00e6c58da58186e511425f7470ed.zip
remove broken stream implementation
Diffstat (limited to '')
-rw-r--r--src/writer.rs10
1 files changed, 8 insertions, 2 deletions
diff --git a/src/writer.rs b/src/writer.rs
index 5f9f3fd..013d37b 100644
--- a/src/writer.rs
+++ b/src/writer.rs
@@ -1,7 +1,13 @@
-use std::{collections::HashSet, pin::pin, str::FromStr};
+use std::{
+ collections::{HashSet, VecDeque},
+ pin::pin,
+ str::FromStr,
+ task::Poll,
+};
use async_recursion::async_recursion;
-use futures::Sink;
+use circular::Buffer;
+use futures::{Future, FutureExt, Sink, SinkExt};
use tokio::io::{AsyncWrite, AsyncWriteExt};
use crate::{