diff options
| -rw-r--r-- | rwcancel/rwcancel.go | 12 |
1 files changed, 1 insertions, 11 deletions
diff --git a/rwcancel/rwcancel.go b/rwcancel/rwcancel.go index 7d50f83..8a6300a 100644 --- a/rwcancel/rwcancel.go +++ b/rwcancel/rwcancel.go @@ -46,17 +46,7 @@ func NewRWCancel(fd int) (*RWCancel, error) { } func RetryAfterError(err error) bool { - if pe, ok := err.(*os.PathError); ok { - err = pe.Err - } - if errno, ok := err.(syscall.Errno); ok { - switch errno { - case syscall.EAGAIN, syscall.EINTR: - return true - } - - } - return false + return errors.Is(err, syscall.EAGAIN) || errors.Is(err, syscall.EINTR) } func (rw *RWCancel) ReadyRead() bool { |