We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4a493e1 commit 05755aeCopy full SHA for 05755ae
src/asynchronous/client.rs
@@ -11,7 +11,6 @@ use std::sync::atomic::{AtomicU32, Ordering};
11
use std::sync::{Arc, Mutex};
12
13
use async_trait::async_trait;
14
-use nix::unistd::close;
15
use tokio::{self, sync::mpsc, task};
16
17
use crate::common::client_connect;
@@ -162,19 +161,6 @@ impl Client {
162
161
}
163
164
165
-struct ClientClose {
166
- fd: RawFd,
167
- close_fd: RawFd,
168
-}
169
-
170
-impl Drop for ClientClose {
171
- fn drop(&mut self) {
172
- close(self.close_fd).unwrap();
173
- close(self.fd).unwrap();
174
- trace!("All client is droped");
175
- }
176
177
178
#[derive(Debug)]
179
struct ClientBuilder {
180
rx: Option<MessageReceiver>,
0 commit comments