Merge pull request #3434 from zkerriga/fix-udp-timouts-ordering-25x

mpilquist · web-flow · commit 8fe0b5959d88 · 2024-05-16T13:06:43.000-04:00
Fix Ordering of UDP pending timeouts
diff --git a/io/src/main/scala/fs2/io/udp/AsynchronousSocketGroup.scala b/io/src/main/scala/fs2/io/udp/AsynchronousSocketGroup.scala
@@ -92,7 +92,7 @@ private[udp] object AsynchronousSocketGroup {
         def apply(duration: FiniteDuration)(onTimeout: => Unit): Timeout =
           new Timeout(System.currentTimeMillis + duration.toMillis, () => onTimeout)
         implicit val ordTimeout: Ordering[Timeout] =
-          Ordering.by[Timeout, Long](_.expiry)
+          Ordering.by[Timeout, Long](_.expiry).reverse
       }
 
       private class Attachment(

Original file line number	Diff line number	Diff line change
`@@ -92,7 +92,7 @@ private[udp] object AsynchronousSocketGroup {`
`92`	`92`	`def apply(duration: FiniteDuration)(onTimeout: => Unit): Timeout =`
`93`	`93`	`new Timeout(System.currentTimeMillis + duration.toMillis, () => onTimeout)`
`94`	`94`	`implicit val ordTimeout: Ordering[Timeout] =`
`95`		`- Ordering.by[Timeout, Long](_.expiry)`
	`95`	`+ Ordering.by[Timeout, Long](_.expiry).reverse`
`96`	`96`	`}`
`97`	`97`
`98`	`98`	`private class Attachment(`