multipart-write 0.1.0

use crate::MultipartWrite;

use std::io::Write;
use std::pin::Pin;
use std::task::{Context, Poll};

pin_project_lite::pin_project! {
    /// The writer returned by [`io_writer`](super::io_writer).
    #[derive(Debug, Default)]
    pub struct MultiIoWriter<W: Write> {
        inner: W,
    }
}

impl<W: Write> MultiIoWriter<W> {
    pub(super) fn new(inner: W) -> Self {
        Self { inner }
    }
}

impl<W: Write + Default> MultipartWrite<&[u8]> for MultiIoWriter<W> {
    type Error = std::io::Error;
    type Output = W;
    type Recv = usize;

    fn poll_ready(
        self: Pin<&mut Self>,
        _cx: &mut Context<'_>,
    ) -> Poll<Result<(), Self::Error>> {
        Poll::Ready(Ok(()))
    }

    fn start_send(
        self: Pin<&mut Self>,
        part: &[u8],
    ) -> Result<Self::Recv, Self::Error> {
        self.get_mut().inner.write(part)
    }

    fn poll_flush(
        self: Pin<&mut Self>,
        _cx: &mut Context<'_>,
    ) -> Poll<Result<(), Self::Error>> {
        Poll::Ready(self.get_mut().inner.flush())
    }

    fn poll_complete(
        mut self: Pin<&mut Self>,
        _cx: &mut Context<'_>,
    ) -> Poll<Result<Self::Output, Self::Error>> {
        Poll::Ready(Ok(std::mem::take(&mut self.inner)))
    }
}