Merge pull request #1043 from xuwei-k/scalafmt-wildcard-syntax

update `.scalafmt.conf`. enforce new wildcard syntax

Author: mkurz

.scalafmt.conf

@@ -12,3 +12,10 @@ spaces.inImportCurlyBraces = true   # more idiomatic to include whitepsace in im
 trailingCommas = preserve
 newlines.afterCurlyLambda = preserve
 version = 3.9.8
+rewrite.scala3.convertToNewSyntax = true
+rewrite.scala3.newSyntax.control = false
+runner.dialectOverride {
+  allowSignificantIndentation = false
+  allowAsForImportRename = false
+  allowStarWildcardImport = false
+}

integration-tests/src/test/scala/play/api/libs/ws/ahc/XMLRequestSpec.scala

@@ -46,7 +46,7 @@ class XMLRequestSpec extends Specification with AfterAll with MustMatchers {
 
     override def bodyAsBytes: ByteString = ByteString.fromArray(byteArray)
 
-    override def bodyAsSource: org.apache.pekko.stream.scaladsl.Source[ByteString, _] = ???
+    override def bodyAsSource: org.apache.pekko.stream.scaladsl.Source[ByteString, ?] = ???
   }
 
   "write an XML node" in {

play-ahc-ws-standalone/src/main/scala/play/api/libs/oauth/OAuth.scala

@@ -107,7 +107,7 @@ class OAuthCalculator(consumerKey: ConsumerKey, requestToken: RequestToken)
   private val ahcRequestToken = new AHCRequestToken(requestToken.token, requestToken.secret)
   private val calculator      = new OAuthSignatureCalculator(ahcConsumerKey, ahcRequestToken)
 
-  override def calculateAndAddSignature(request: Request, requestBuilder: RequestBuilderBase[_]): Unit = {
+  override def calculateAndAddSignature(request: Request, requestBuilder: RequestBuilderBase[?]): Unit = {
     calculator.calculateAndAddSignature(request, requestBuilder)
   }
 }

play-ahc-ws-standalone/src/main/scala/play/api/libs/ws/ahc/AhcLoggerFactory.scala

@@ -24,7 +24,7 @@ class AhcLoggerFactory(lf: ILoggerFactory = SLF4JLoggerFactory.getILoggerFactory
     }
   }
 
-  def apply(clazz: Class[_]): NoDepsLogger = createLogger(clazz.getName)
+  def apply(clazz: Class[?]): NoDepsLogger = createLogger(clazz.getName)
   def apply(name: String): NoDepsLogger    = createLogger(name)
 
 }

play-ahc-ws-standalone/src/main/scala/play/api/libs/ws/ahc/StandaloneAhcWSClient.scala

@@ -113,7 +113,7 @@ class StandaloneAhcWSClient @Inject() (asyncHttpClient: AsyncHttpClient)(implici
 
       val wrap = new Publisher[HttpResponseBodyPart]() {
         override def subscribe(
-            s: Subscriber[_ >: HttpResponseBodyPart]
+            s: Subscriber[? >: HttpResponseBodyPart]
         ): Unit = {
           publisher.subscribe(new Subscriber[HttpResponseBodyPart] {
             override def onSubscribe(sub: Subscription): Unit =
@@ -155,7 +155,7 @@ class StandaloneAhcWSClient @Inject() (asyncHttpClient: AsyncHttpClient)(implici
     streamStarted.future
   }
 
-  private[ahc] def blockingToByteString(bodyAsSource: Source[ByteString, _]) = {
+  private[ahc] def blockingToByteString(bodyAsSource: Source[ByteString, ?]) = {
     StandaloneAhcWSClient.logger.warn(
       s"blockingToByteString is a blocking and unsafe operation!"
     )

play-ahc-ws-standalone/src/main/scala/play/api/libs/ws/ahc/StandaloneAhcWSResponse.scala

@@ -47,7 +47,7 @@ class StandaloneAhcWSResponse(ahcResponse: AHCResponse)
    */
   override lazy val bodyAsBytes: ByteString = ByteString.fromArray(underlying[AHCResponse].getResponseBodyAsBytes)
 
-  override lazy val bodyAsSource: Source[ByteString, _] = Source.single(bodyAsBytes)
+  override lazy val bodyAsSource: Source[ByteString, ?] = Source.single(bodyAsBytes)
 }
 
 object StandaloneAhcWSResponse {

play-ahc-ws-standalone/src/main/scala/play/api/libs/ws/ahc/Streamed.scala

@@ -79,7 +79,7 @@ class DefaultStreamedAsyncHandler[T](
 }
 
 private case object EmptyPublisher extends Publisher[HttpResponseBodyPart] {
-  def subscribe(s: Subscriber[_ >: HttpResponseBodyPart]): Unit = {
+  def subscribe(s: Subscriber[? >: HttpResponseBodyPart]): Unit = {
     if (s eq null)
       throw new NullPointerException("Subscriber must not be null, rule 1.9")
     s.onSubscribe(CancelledSubscription)

play-ahc-ws-standalone/src/main/scala/play/api/libs/ws/ahc/StreamedResponse.scala

@@ -115,7 +115,7 @@ class StreamedResponse(
    */
   override lazy val bodyAsBytes: ByteString = client.blockingToByteString(bodyAsSource)
 
-  override lazy val bodyAsSource: Source[ByteString, _] = {
+  override lazy val bodyAsSource: Source[ByteString, ?] = {
     Source
       .fromPublisher(publisher)
       .map((bodyPart: HttpResponseBodyPart) => ByteString.fromArray(bodyPart.getBodyPartBytes))

play-ahc-ws-standalone/src/main/scala/play/api/libs/ws/ahc/cache/CacheAsyncConnection.scala

@@ -52,7 +52,7 @@ class AsyncCacheableConnection[T](
       }
 
       asyncHandler match {
-        case progressAsyncHandler: ProgressAsyncHandler[_] =>
+        case progressAsyncHandler: ProgressAsyncHandler[?] =>
           progressAsyncHandler.onHeadersWritten()
           progressAsyncHandler.onContentWritten()
         case _ =>

play-ahc-ws-standalone/src/main/scala/play/api/libs/ws/ahc/cache/CachingAsyncHttpClient.scala

@@ -63,7 +63,7 @@ class CachingAsyncHttpClient(underlying: AsyncHttpClient, ahcHttpCache: AhcHttpC
   }
 
   @throws(classOf[IOException])
-  protected def execute[T](request: Request, handler: AsyncCompletionHandler[T], future: ListenableFuture[_])(implicit
+  protected def execute[T](request: Request, handler: AsyncCompletionHandler[T], future: ListenableFuture[?])(implicit
       ec: ExecutionContext
   ): ListenableFuture[T] = {
     if (logger.isTraceEnabled) {