Trait EtcdConnector 

pub trait EtcdConnector {
    type WatchStream: Stream<Item = Result<WatchResponse, Error>> + Unpin + Send + 'static;
    type ConnectFut: Future<Output = Result<Self::WatchStream, Error>> + Send + 'static;

    // Required method
    fn connect_watch(
        &mut self,
        last_revision: Option<Revision>,
    ) -> Self::ConnectFut;
}

Required Associated Types

type WatchStream: Stream<Item = Result<WatchResponse, Error>> + Unpin + Send + 'static

type ConnectFut: Future<Output = Result<Self::WatchStream, Error>> + Send + 'static

Required Methods

fn connect_watch(&mut self, last_revision: Option<Revision>) -> Self::ConnectFut

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl EtcdConnector for GrpcEtcdConenctor

type WatchStream = WatchStream

type ConnectFut = Pin<Box<dyn Future<Output = Result<<GrpcEtcdConenctor as EtcdConnector>::WatchStream, Error>> + Send>>