diff --git a/connection_unix.go b/connection_unix.go index ba7cffa77..3269847d7 100644 --- a/connection_unix.go +++ b/connection_unix.go @@ -442,14 +442,14 @@ func (c *conn) AsyncWrite(buf []byte, callback AsyncCallback) error { } return err } - return c.loop.poller.Trigger(c.asyncWrite, &asyncWriteHook{callback, buf}) + return c.loop.poller.UrgentTrigger(c.asyncWrite, &asyncWriteHook{callback, buf}) } func (c *conn) AsyncWritev(bs [][]byte, callback AsyncCallback) error { if c.isDatagram { return errorx.ErrUnsupportedOp } - return c.loop.poller.Trigger(c.asyncWritev, &asyncWritevHook{callback, bs}) + return c.loop.poller.UrgentTrigger(c.asyncWritev, &asyncWritevHook{callback, bs}) } func (c *conn) Wake(callback AsyncCallback) error {