path: root/src/writer.rs

use futures::{AsyncWrite, Sink};

use crate::{
    element::{Element, Name, Namespace},
    error::Error,
};

pub struct Writer<W> {
    stream: W,
    depth: Vec<Name>,
    namespaces: Vec<(usize, Namespace)>,
}

impl<W: AsyncWrite> Writer<W> {
    pub async fn write(&self, element: impl Into<Element>) -> Result<(), Error> {}
    pub async fn write_start(&self, element: impl Into<Element>) -> Result<(), Error> {}
    pub async fn write_end(&self) -> Result<(), Error> {}
}

impl<W: AsyncWrite, E: Into<Element>> Sink<E> for Writer<W> {
    type Error = Error;

    fn poll_ready(
        self: std::pin::Pin<&mut Self>,
        cx: &mut std::task::Context<'_>,
    ) -> std::task::Poll<Result<(), Self::Error>> {
        todo!()
    }

    fn start_send(self: std::pin::Pin<&mut Self>, item: E) -> Result<(), Self::Error> {
        todo!()
    }

    fn poll_flush(
        self: std::pin::Pin<&mut Self>,
        cx: &mut std::task::Context<'_>,
    ) -> std::task::Poll<Result<(), Self::Error>> {
        todo!()
    }

    fn poll_close(
        self: std::pin::Pin<&mut Self>,
        cx: &mut std::task::Context<'_>,
    ) -> std::task::Poll<Result<(), Self::Error>> {
        todo!()
    }
}