Struct futures_loco_protocol::LocoClient

pub struct LocoClient<T> { /* private fields */ }

Implementations

impl<T> LocoClient<T>

pub const MAX_READ_SIZE: u64 = 16_777_216u64

pub const fn new(inner: T) -> Self

pub const fn inner(&self) -> &T

pub fn inner_mut(&mut self) -> &mut T

pub fn inner_pin_mut(self: Pin<&mut Self>) -> Pin<&mut T>

pub fn into_inner(self) -> T

impl<T: AsyncRead> LocoClient<T>

pub async fn read(&mut self) -> Result<BoxedCommand>where T: Unpin,

pub fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_> ) -> Poll<Result<BoxedCommand>>

impl<T: AsyncWrite> LocoClient<T>

pub async fn send(&mut self, method: Method, data: &[u8]) -> Result<u32>where T: Unpin,

pub fn write(self: Pin<&mut Self>, method: Method, data: &[u8]) -> u32

pub fn poll_flush( self: Pin<&mut Self>, cx: &mut Context<'_> ) -> Poll<Result<()>>

impl<T: AsyncRead + AsyncWrite + Unpin> LocoClient<T>

pub async fn request( &mut self, method: Method, data: &[u8] ) -> Result<impl Future<Output = Result<BoxedCommand>> + '_>

Trait Implementations

impl<T: Debug> Debug for LocoClient<T>

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

Formats the value using the given formatter.

impl<'__pin, T> Unpin for LocoClient<T>where __Origin<'__pin, T>: Unpin,