Struct Connection 

pub struct Connection { /* private fields */ }

Implementations

impl Connection

pub async fn new(endpoint: &SocketAddr) -> Result<Self, ClientError>

Establish a connection to the given socket address.

Examples

use rocketmq_client::connection::Connection;
use std::net::SocketAddr;

#[tokio::main]
fn main() {
   let endpoint = "127.0.0.1:80";
   let socket_addr = endpoint.parse::<std::net::SocketAddr>().unwrap();
   let connection = rocketmq_client::connection::Connection::new(&socket_addr).await.unwrap();
}

Errors

Raise ClientError::ConnectTimeout if connection may not be established within reasonable amount of time.

pub async fn read_frame(&mut self) -> Result<Option<Frame>, ClientError>

pub async fn write_frame(&mut self, frame: &Frame) -> Result<(), ClientError>