From 4f0691de7d8d00e6c58da58186e511425f7470ed Mon Sep 17 00:00:00 2001 From: cel 🌸 Date: Fri, 6 Dec 2024 06:33:10 +0000 Subject: remove broken stream implementation --- src/writer.rs | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) (limited to 'src/writer.rs') 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::{ -- cgit