Enum Stream

pub enum Stream<S> {
    Raw(S),
    Ssl(TlsStream<S>),
}

This a wrapper to work equals for a stream and a TLS stream

Variants

Raw(S)

Raw stream that implement Read + Write

Ssl(TlsStream<S>)

TLS Stream

Implementations

impl<S: Read + Write> Stream<S>

pub fn read_exact(&mut self, buf: &mut [u8]) -> RdpResult<()>

Read exactly the number of bytes present in buffer

Example

use rdp::model::link::Stream;
use std::io::Cursor;
let mut s = Stream::Raw(Cursor::new(vec![1, 2, 3]));
let mut result = [0, 0];
s.read_exact(&mut result).unwrap();
assert_eq!(result, [1, 2])

pub fn read(&mut self, buf: &mut [u8]) -> RdpResult<usize>

Read all available buffer

Example

use rdp::model::link::Stream;
use std::io::Cursor;
let mut s = Stream::Raw(Cursor::new(vec![1, 2, 3]));
let mut result = [0, 0, 0, 0];
s.read(&mut result).unwrap();
assert_eq!(result, [1, 2, 3, 0])

pub fn write(&mut self, buffer: &[u8]) -> RdpResult<usize>

Write all buffer to the stream

Example

use rdp::model::link::Stream;
use std::io::Cursor;
let mut s = Stream::Raw(Cursor::new(vec![]));
let result = [1, 2, 3, 4];
s.write(&result).unwrap();
if let Stream::Raw(r) = s {
    assert_eq!(r.into_inner(), [1, 2, 3, 4])
}
else {
    panic!("invalid")
}

pub fn shutdown(&mut self) -> RdpResult<()>

Shutdown the stream Only works when stream is a SSL stream