File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
core/shared/src/main/scala/fs2/concurrent Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -290,9 +290,9 @@ object SignallingRef {
290290 def cleanup (id : Long ): F [Unit ] =
291291 state.update(s => s.copy(listeners = s.listeners - id))
292292
293- Resource .eval(state.get) .map { s =>
293+ Resource .eval(state.get.map { s =>
294294 (s.value, Stream .bracket(newId)(cleanup).flatMap(go(_, s.lastUpdate)))
295- }
295+ })
296296 }
297297
298298 def set (a : A ): F [Unit ] = update(_ => a)
@@ -570,14 +570,14 @@ object SignallingMapRef {
570570 }
571571 }
572572
573- Resource .eval(state.get) .map { state =>
573+ Resource .eval(state.get.map { state =>
574574 (
575575 state.keys.get(k).flatMap(_.value),
576576 Stream
577577 .bracket(newId)(cleanup)
578578 .flatMap(go(_, state.keys.get(k).fold(- 1L )(_.lastUpdate)))
579579 )
580- }
580+ })
581581 }
582582
583583 def set (v : Option [V ]): F [Unit ] = update(_ => v)
You can’t perform that action at this time.
0 commit comments