diff options
author | 2024-12-06 06:33:10 +0000 | |
---|---|---|
committer | 2024-12-06 06:33:10 +0000 | |
commit | 4f0691de7d8d00e6c58da58186e511425f7470ed (patch) | |
tree | 7ef46d1fa3f588f16d1b68624d47e9f9deea9af5 /src/writer.rs | |
parent | 1d831b4c4e730a7a7a4556e6c71aecc88d73d9ee (diff) | |
download | peanuts-4f0691de7d8d00e6c58da58186e511425f7470ed.tar.gz peanuts-4f0691de7d8d00e6c58da58186e511425f7470ed.tar.bz2 peanuts-4f0691de7d8d00e6c58da58186e511425f7470ed.zip |
remove broken stream implementation
Diffstat (limited to '')
-rw-r--r-- | src/writer.rs | 10 |
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::{ |