diff options
Diffstat (limited to 'src/reader.rs')
-rw-r--r-- | src/reader.rs | 34 |
1 files changed, 19 insertions, 15 deletions
diff --git a/src/reader.rs b/src/reader.rs index 26e540e..6e622f4 100644 --- a/src/reader.rs +++ b/src/reader.rs @@ -18,21 +18,25 @@ impl<R> Reader<R> where R: AsyncBufRead, { - pub async fn read(&self) -> Result<impl From<Element>, Error> { - let buf = self.stream.poll_fill_buf().await?; - todo!() - } - pub async fn read_start(&self) -> Result<impl From<Element>, Error> {} - pub async fn read_end(&self) -> Result<(), Error> {} + // pub async fn read(&self) -> Result<impl From<Element>, Error> { + // let buf = self.stream.poll_fill_buf().await?; + // todo!() + // } + // pub async fn read_start(&self) -> Result<impl From<Element>, Error> { + // todo!() + // } + // pub async fn read_end(&self) -> Result<(), Error> { + // todo!() + // } } -impl<R: AsyncBufRead> Stream for Reader<R> { - type Item = impl From<Element>; +// impl<R: AsyncBufRead> Stream for Reader<R> { +// type Item = impl From<Element>; - async fn poll_next( - self: std::pin::Pin<&mut Self>, - cx: &mut std::task::Context<'_>, - ) -> std::task::Poll<Option<Self::Item>> { - todo!() - } -} +// async fn poll_next( +// self: std::pin::Pin<&mut Self>, +// cx: &mut std::task::Context<'_>, +// ) -> std::task::Poll<Option<Self::Item>> { +// todo!() +// } +// } |