Struct kf_socket::KfSink

pub struct KfSink { /* fields omitted */ }

Methods

impl KfSink

pub fn new(
    inner: SplitSink<Framed<AsyncTcpStream, KfCodec>, Bytes>,
    fd: RawFd
) -> Self

pub fn get_mut_tcp_sink(
    &mut self
) -> &mut SplitSink<Framed<AsyncTcpStream, KfCodec>, Bytes>

pub async fn send_request<'_, '_, R>(
    &'_ mut self,
    req_msg: &'_ RequestMessage<R>
) -> Result<(), KfSocketError> where
    RequestMessage<R>: KfEncoder + Default + Debug, 

as client, send request to server

pub async fn send_response<'_, '_, P>(
    &'_ mut self,
    resp_msg: &'_ ResponseMessage<P>,
    version: Version
) -> Result<(), KfSocketError> where
    ResponseMessage<P>: KfEncoder + Default + Debug, 

as server, send back response

pub async fn encode_file_slices<'_, '_, T>(
    &'_ mut self,
    msg: &'_ T,
    version: Version
) -> Result<(), KfSocketError> where
    T: FileWrite, 

write

Trait Implementations

impl AsRawFd for KfSink

fn as_raw_fd(&self) -> RawFd

Extracts the raw file descriptor.

impl Debug for KfSink

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

Formats the value using the given formatter.

impl ZeroCopyWrite for KfSink

fn zero_copy_write<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    source: &'life1 AsyncFileSlice
) -> Pin<Box<dyn Future<Output = Result<usize, SendFileError>> + 'async_trait + Send>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: Send + 'async_trait,