in quark.go [251:258]
func (queue *Queue) Block() error { event := make([]syscall.EpollEvent, 1) _, err := syscall.EpollWait(queue.epollFd, event, 100) if err != nil && errors.Is(err, syscall.EINTR) { err = nil } return err }