Struct kf_socket::InnerKfSocket

pub struct InnerKfSocket<S> { /* fields omitted */ }

KfSocket is high level socket that can send and receive kf-protocol

Implementations

impl<S> InnerKfSocket<S>

pub fn new(sink: InnerKfSink<S>, stream: InnerKfStream<S>) -> Self

pub fn split(self) -> (InnerKfSink<S>, InnerKfStream<S>)

pub fn set_stale(&mut self)

mark as stale

pub fn is_stale(&self) -> bool

pub fn get_mut_sink(&mut self) -> &mut InnerKfSink<S>

pub fn get_mut_stream(&mut self) -> &mut InnerKfStream<S>

impl<S> InnerKfSocket<S> where
    S: AsyncRead + AsyncWrite + Unpin + Send, 

pub async fn connect_with_connector<'_, '_, C>(
    addr: &'_ str,
    connector: &'_ C
) -> Result<Self, KfSocketError> where
    C: TcpDomainConnector<WrapperStream = S>, 

connect to target address with connector

pub fn from_stream(tcp_stream: S, raw_fd: RawFd) -> Self

pub async fn send<'_, '_, R>(
    &'_ mut self,
    req_msg: &'_ RequestMessage<R>
) -> Result<ResponseMessage<R::Response>, KfSocketError> where
    R: Request, 

as client, send request and wait for reply from server

impl InnerKfSocket<TcpStream>

pub async fn connect<'_>(addr: &'_ str) -> Result<Self, KfSocketError>

Trait Implementations

impl<S: Debug> Debug for InnerKfSocket<S>

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

Formats the value using the given formatter.

impl<S> From<(InnerKfSink<S>, InnerKfStream<S>)> for InnerKfSocket<S>

fn from(pair: (InnerKfSink<S>, InnerKfStream<S>)) -> Self

Performs the conversion.

impl<S> Sync for InnerKfSocket<S>