Fix broken pipe waker

Author: Darksonn

src/sys/unix/selector/kqueue.rs

@@ -1,20 +1,16 @@
 use std::mem;
+use std::mem::MaybeUninit;
 use std::ops::{Deref, DerefMut};
 use std::os::fd::{AsRawFd, FromRawFd, OwnedFd, RawFd};
+use std::slice;
 #[cfg(debug_assertions)]
 use std::sync::atomic::{AtomicUsize, Ordering};
 use std::time::Duration;
 use std::{cmp, io, ptr};
 
+use crate::Interest;
 use crate::Token;
 
-cfg_io_source! {
-    use std::mem::MaybeUninit;
-    use std::slice;
-
-    use crate::Interest;
-}
-
 /// Unique id for use as `SelectorId`.
 #[cfg(debug_assertions)]
 static NEXT_ID: AtomicUsize = AtomicUsize::new(1);
@@ -129,7 +125,6 @@ impl Selector {
         })
     }
 
-    cfg_io_source! {
     pub fn register(&self, fd: RawFd, token: Token, interests: Interest) -> io::Result<()> {
         let flags = libc::EV_CLEAR | libc::EV_RECEIPT | libc::EV_ADD;
         // At most we need two changes, but maybe we only need 1.
@@ -169,6 +164,7 @@ impl Selector {
         kevent_register(self.kq.as_raw_fd(), changes, &[libc::EPIPE as i64])
     }
 
+    cfg_io_source! {
     pub fn reregister(&self, fd: RawFd, token: Token, interests: Interest) -> io::Result<()> {
         let flags = libc::EV_CLEAR | libc::EV_RECEIPT;
         let write_flags = if interests.is_writable() {