diff --git a/.git-blame-ignore-revs b/.git-blame-ignore-revs index f1b63b6d..8dc88681 100644 --- a/.git-blame-ignore-revs +++ b/.git-blame-ignore-revs @@ -3,3 +3,6 @@ ee0c7d79b3a923abf9e7dc6c10e3fc24451d1291 # Scala Steward: Reformat with scalafmt 3.7.1 bd6d426709861daca710e9781bd5b92260c63f38 + +# Scala Steward: Reformat with scalafmt 3.8.5 +931c6602a271cbd6d8fd6dbe4c8a3ec9f495b98b diff --git a/.scalafmt.conf b/.scalafmt.conf index f12f4a60..b68d9a62 100644 --- a/.scalafmt.conf +++ b/.scalafmt.conf @@ -1,4 +1,4 @@ -version = 3.8.3 +version = 3.8.5 runner.dialect = scala213source3 diff --git a/fs2/src/main/scala/laserdisc/fs2/PromiseMapper.scala b/fs2/src/main/scala/laserdisc/fs2/PromiseMapper.scala index 843e9d20..89ed8923 100644 --- a/fs2/src/main/scala/laserdisc/fs2/PromiseMapper.scala +++ b/fs2/src/main/scala/laserdisc/fs2/PromiseMapper.scala @@ -40,11 +40,10 @@ object PromiseMapper extends Poly1 { val complete: Maybe[A] => F[Unit] = mba => promise.complete(mba).as(()) - queue.offer(Request(protocol, complete)) >> { + queue.offer(Request(protocol, complete)) >> promise.get .timeout(duration) .adaptError { case _: TimeoutException => RequestTimedOut(protocol) } - } } }