Struct embedded_redis::network::Future

pub struct Future<'a, N: TcpClientStack, C: Clock, P: Protocol, Cmd: Command<P::FrameType>> { /* private fields */ }

Non-blocking response management

Implementations

impl<'a, N: TcpClientStack, C: Clock, P: Protocol, Cmd: Command<P::FrameType>> Future<'a, N, C, P, Cmd>

pub fn wait(self) -> Result<Cmd::Response, CommandErrors>

Blocks until response is received and returns the response Throws an error on invalid response or timeout (if configured)

pub fn ready(&mut self) -> bool

Non blocking method for checking if data is ready So if true is returned, wait() is non-blocking Reads all pending data and returns true if response is ready Errors are preserved and returned on wait() call

Trait Implementations

impl<'a, N: TcpClientStack, C: Clock, P: Protocol, Cmd: Command<P::FrameType>> Drop for Future<'a, N, C, P, Cmd>

fn drop(&mut self)

Executes the destructor for this type.