tunnels 0.1.0

Dev Tunnels SDK
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

// Copyright (c) Microsoft Corporation.
// Licensed under the MIT license.

use std::task::Poll;

/// Helper used when converting Future interfaces to poll-based interfaces.
/// Stores excess data that can be reused on future polls.
#[derive(Default)]
pub(crate) struct ReadBuffer(Option<(Vec<u8>, usize)>);

impl ReadBuffer {
    /// Removes any data stored in the read buffer
    pub fn take_data(&mut self) -> Option<(Vec<u8>, usize)> {
        self.0.take()
    }

    /// Writes as many bytes as possible to the readbuf, stashing any extra.
    pub fn put_data(
        &mut self,
        target: &mut tokio::io::ReadBuf<'_>,
        bytes: Vec<u8>,
        start: usize,
    ) -> Poll<std::io::Result<()>> {
        if bytes.is_empty() {
            self.0 = None;
            // should not return Ok(), since if nothing is written to the target
            // it signals EOF. Instead wait for more data from the source.
            return Poll::Pending;
        }

        if target.remaining() >= bytes.len() - start {
            target.put_slice(&bytes[start..]);
            self.0 = None;
        } else {
            let end = start + target.remaining();
            target.put_slice(&bytes[start..end]);
            self.0 = Some((bytes, end));
        }

        Poll::Ready(Ok(()))
    }
}