Struct Connector

pub struct Connector { /* private fields */ }

Connector

Implementations

impl Connector

pub fn connect_with_addr<S: Into<SocketAddr>>(&self, addr: S) -> Result<Socket>

Connect to a remote endpoint with addr

Examples found in repository

examples/tcp_socket.rs (line 14)

fn ssh() {
  let add = SocketAddr::new(IpAddr::V4(Ipv4Addr::new(127, 0, 0, 1)), 22);
  let timeout = Duration::new(3, 0);
  let mut socket = slinger::Connector::default()
    .connect_with_addr(add)
    .unwrap();
  socket.set_write_timeout(Some(timeout)).unwrap();
  socket.set_read_timeout(Some(timeout)).unwrap();
  socket.write_all(b"\r\n").unwrap();
  socket.flush().unwrap();
  let mut buf = [0u8; 1];
  let mut full = Vec::new();
  while let Ok(size) = socket.read(&mut buf) {
    if size == 0 {
      break;
    }
    full.extend(buf);
  }
  println!("{:?}", String::from_utf8_lossy(&full));
  socket.shutdown(Shutdown::Both).unwrap();
}

fn redis() {
  let add = SocketAddr::new(IpAddr::V4(Ipv4Addr::new(127, 0, 0, 1)), 6379);
  let timeout = Duration::new(3, 0);
  let mut socket = slinger::Connector::default()
    .connect_with_addr(add)
    .unwrap();
  socket.set_write_timeout(Some(timeout)).unwrap();
  socket.set_read_timeout(Some(timeout)).unwrap();
  socket.write_all(b"*1\r\n$4\r\ninfo\r\n").unwrap();
  socket.flush().unwrap();
  let mut buf = [0u8; 1];
  let mut full = Vec::new();
  while let Ok(size) = socket.read(&mut buf) {
    if size == 0 {
      break;
    }
    full.extend(buf);
  }
  println!("{:?}", String::from_utf8_lossy(&full));
  socket.shutdown(Shutdown::Both).unwrap();
}

pub fn connect_with_uri(&self, target: &Uri) -> Result<Socket>

Connect to a remote endpoint with url

Trait Implementations

impl Debug for Connector

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for Connector

fn default() -> Self

Returns the “default value” for a type.

impl PartialEq for Connector

fn eq(&self, _other: &Self) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.