aboutsummaryrefslogtreecommitdiffstats
path: root/src/reader.rs
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--src/reader.rs34
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!()
+// }
+// }