Struct WatchStream 

pub struct WatchStream(/* private fields */);

Implementations

impl WatchStream

pub async fn message(&mut self) -> Result<Option<String>>

Example

use mcmc_rs::{Connection, WatchArg};

for (mut c1, mut c2) in [
    (Connection::default().await?, Connection::default().await?),
    (
        Connection::unix_connect("/tmp/memcached0.sock").await?,
        Connection::unix_connect("/tmp/memcached0.sock").await?,
    ),
    (
        Connection::tls_connect("localhost", 11216, "cert.pem").await?,
        Connection::tls_connect("localhost", 11216, "cert.pem").await?,
    ),
] {
    let mut w = c1.watch(&[WatchArg::Fetchers]).await?;
    c2.get(b"key").await?;
    let result = w.message().await?;
    assert!(result.is_some())
}