diff --git a/.git-blame-ignore-revs b/.git-blame-ignore-revs index b9d73fe..84696a2 100644 --- a/.git-blame-ignore-revs +++ b/.git-blame-ignore-revs @@ -1,2 +1,5 @@ # Scala Steward: Reformat with scalafmt 3.5.9 5249343b1acf33cf5828a8c16ccb02decc1021ad + +# Scala Steward: Reformat with scalafmt 3.10.2 +8fb0840702a055bdb787e56aabd29b8c7971feac diff --git a/.scalafmt.conf b/.scalafmt.conf index 565785f..6dd0d37 100644 --- a/.scalafmt.conf +++ b/.scalafmt.conf @@ -1,5 +1,5 @@ # copied from https://github.com/typelevel/fs2/blob/main/.scalafmt.conf -version = "3.8.6" +version = "3.10.2" runner.dialect = scala213 diff --git a/ce3/src/main/scala/ru/delimobil/cabbit/client/consumer/ChannelDeferredConsumerProvider.scala b/ce3/src/main/scala/ru/delimobil/cabbit/client/consumer/ChannelDeferredConsumerProvider.scala index c34b06d..03b13a1 100644 --- a/ce3/src/main/scala/ru/delimobil/cabbit/client/consumer/ChannelDeferredConsumerProvider.scala +++ b/ce3/src/main/scala/ru/delimobil/cabbit/client/consumer/ChannelDeferredConsumerProvider.scala @@ -66,6 +66,8 @@ private[client] final class ChannelDeferredConsumerProvider[F[_]: Async]( object ChannelDeferredConsumerProvider { - def make[F[_]: Async](shouldRaiseOnShutdown: Boolean): Resource[F, ChannelDeferredConsumerProvider[F]] = + def make[F[_]: Async]( + shouldRaiseOnShutdown: Boolean + ): Resource[F, ChannelDeferredConsumerProvider[F]] = Dispatcher.parallel[F].map(new ChannelDeferredConsumerProvider[F](_, shouldRaiseOnShutdown)) }