svn 0.1.8

Async Rust SVN client for Subversion svn://, svn+ssh://, and ra_svn workflows.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

use super::*;

pub(super) struct LimitedVecWriter {
    buf: Vec<u8>,
    max_bytes: u64,
}

impl LimitedVecWriter {
    pub(super) fn new(max_bytes: u64) -> Self {
        Self {
            buf: Vec::new(),
            max_bytes,
        }
    }

    pub(super) fn into_inner(self) -> Vec<u8> {
        self.buf
    }
}

impl AsyncWrite for LimitedVecWriter {
    fn poll_write(
        mut self: Pin<&mut Self>,
        _cx: &mut Context<'_>,
        buf: &[u8],
    ) -> Poll<std::io::Result<usize>> {
        let next = (self.buf.len() as u64).saturating_add(buf.len() as u64);
        if next > self.max_bytes {
            return Poll::Ready(Err(std::io::Error::other(format!(
                "buffer exceeds limit {}",
                self.max_bytes
            ))));
        }

        self.buf.extend_from_slice(buf);
        Poll::Ready(Ok(buf.len()))
    }

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

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