From 844f3a5d11e4360e9d6bdb79cfed49287aa8b14d Mon Sep 17 00:00:00 2001
From: cel 🌸 <cel@blos.sm>
Date: Mon, 4 Mar 2024 16:14:28 +0000
Subject: initial commit

---
 src/reader.rs | 32 ++++++++++++++++++++++++++++++++
 1 file changed, 32 insertions(+)
 create mode 100644 src/reader.rs

(limited to 'src/reader.rs')

diff --git a/src/reader.rs b/src/reader.rs
new file mode 100644
index 0000000..05afc73
--- /dev/null
+++ b/src/reader.rs
@@ -0,0 +1,32 @@
+use futures::Stream;
+use tokio::io::AsyncRead;
+
+use crate::{
+    element::{Element, Name, Namespace},
+    error::Error,
+};
+
+/// streaming reader that tracks depth and available namespaces at current depth
+pub struct Reader<R> {
+    stream: R,
+    // holds which tags we are in atm over depth
+    depth: Vec<Name>,
+    namespaces: Vec<(usize, Namespace)>,
+}
+
+impl<R: AsyncRead> Reader<R> {
+    pub async fn read(&self) -> Result<impl From<Element>, Error> {}
+    pub async fn read_start(&self) -> Result<impl From<Element>, Error> {}
+    pub async fn read_end(&self) -> Result<(), Error> {}
+}
+
+impl<R: AsyncRead> 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!()
+    }
+}
-- 
cgit