Merge pull request #3144 from armanbilge/pr/signal-get-and-discrete-u…

…pdates-optimizations Microptimize `Signal#getAndDiscreteUpdates`
typelevel · Feb 15, 2023 · 0dafa1f · 0dafa1f
2 parents 1531919 + 8953891
commit 0dafa1f
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/core/shared/src/main/scala/fs2/concurrent/Signal.scala b/core/shared/src/main/scala/fs2/concurrent/Signal.scala
@@ -287,9 +287,9 @@ object SignallingRef {
             def cleanup(id: Long): F[Unit] =
               state.update(s => s.copy(listeners = s.listeners - id))
 
-            Resource.eval(state.get).map { s =>
+            Resource.eval(state.get.map { s =>
               (s.value, Stream.bracket(newId)(cleanup).flatMap(go(_, s.lastUpdate)))
-            }
+            })
           }
 
           def set(a: A): F[Unit] = update(_ => a)
@@ -565,14 +565,14 @@ object SignallingMapRef {
                   }
                 }
 
-              Resource.eval(state.get).map { state =>
+              Resource.eval(state.get.map { state =>
                 (
                   state.keys.get(k).flatMap(_.value),
                   Stream
                     .bracket(newId)(cleanup)
                     .flatMap(go(_, state.keys.get(k).fold(-1L)(_.lastUpdate)))
                 )
-              }
+              })
             }
 
             def set(v: Option[V]): F[Unit] = update(_ => v)