You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
i write a demo as follow. if the port is not listened , Client try write socket in dead loop.
`use zookeeper::{ZooKeeper, Watcher, WatchedEvent};
use std::time::Duration;
use std::thread;
i write a demo as follow. if the port is not listened , Client try write socket in dead loop.
`use zookeeper::{ZooKeeper, Watcher, WatchedEvent};
use std::time::Duration;
use std::thread;
struct LoggingWatcher;
impl Watcher for LoggingWatcher {
fn handle(&self, e: WatchedEvent) {
println!("{:?}", e)
}
}
fn main() {
env_logger::init();
let url = "127.0.0.1:2081";
let zk = ZooKeeper::connect(url, Duration::from_secs(1), LoggingWatcher).unwrap();
}`
Screen print fail log in dead loop
[2022-09-20T08:57:59Z ERROR zookeeper::io] Failed to write socket: Os { code: 32, kind: BrokenPipe, message: "Broken pipe" }
The text was updated successfully, but these errors were encountered: