Struct makiko::ClientFuture

pub struct ClientFuture<IO> { /* private fields */ }

Future that drives the connection state machine.

This future performs the reads and writes on IO and stores the state of the connection. You must poll this future, usually by spawning a task for it. The future completes when the connection is closed or when an error happens.

Implementations

impl<IO> ClientFuture<IO>

pub fn into_stream(self) -> IO

Deconstructs the future and gives the IO back to you.

Trait Implementations

impl<IO> Future for ClientFuture<IO>where IO: AsyncRead + AsyncWrite,

type Output = Result<(), Error>

The type of value produced on completion.

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

Attempt to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.

impl<'pin, IO> Unpin for ClientFuture<IO>where __ClientFuture<'pin, IO>: Unpin,